- Java 双重比较
- java - 比较器与 Apache BeanComparator
- Objective-C 完成 block 导致额外的方法调用?
- database - RESTful URI 是否应该公开数据库主键?
如果我使用ThreadPoolExecutor
,我有多种构造函数,我可以为池的工作队列传递/使用我自己的队列。
现在我看到 ScheduledThreadPoolExecutor
是 ThreadPoolExecutor
的子类,但构造函数要少得多。
有没有办法在使用 ScheduledThreadPoolExecutor
的同时仍然使用我自己的工作队列?
最佳答案
您可以扩展 ScheduledThreadPoolExecutor
类并使用与绑定(bind)到当前 ScheduledThreadPoolExecutor
实现的 DelayedWorkQueue
不同的队列。请注意,DelayedWorkQueue
只是在后台使用 DelayQueue
的 BlockingQueue
实现。
但是如果你只需要配置min,max,keepAlive或其他参数(不需要改变DelayedWorkQueue
)你将只扩展ThreadPoolExecutor
(类似于ScheduledThreadPoolExecutor
正在做什么)并且在你的构造函数中你将做一些类似于 ScheduledThreadPoolExecutor
构造函数现在正在做的事情,委托(delegate)给 ThreadPoolExecutor
就像:
super(min, max, keepAliveTime, TimeUnit.NANOSECONDS,
new CustomQueue(), threadFactory);
关于java - ScheduledThreadPoolExecutors 和自定义队列,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/13514441/
ScheduledThreadPoolExecutor 扩展自 一文秒懂 Java 线程池之 ThreadPoolExecutor 讲解的 了ThreadPoolExecutor 类,并且添加了其它方
ThreadPoolExecutor 和 ScheduledThreadPoolExecutor 是线程安全的吗?现在,我有一个场景如下: 5 ThreadPoolExecutor(s) exec1(
我有以下类(class) public class MaintanceTools { public static final ScheduledThreadPoolExecutor THREA
我需要更改 ScheduledThreadPoolExecutor 的运行任务的执行时间。 我有类似的东西 executor.schedule(new Runnable() {blablal},10,
我想要一些线程池,它每隔固定的时间运行一些任务(这个线程池一直在获取任务)。每个任务都会调用一些 API 来获取一些值,该值可以为 null。我希望仅当返回值为空时任务才再次运行(在固定时间后)。否则
已关闭。此问题不符合Stack Overflow guidelines 。目前不接受答案。 有关您编写的代码问题的问题必须在问题本身中描述具体问题 - 并包含有效代码以重现该问题。请参阅SSCCE.o
我有一个具有固定延迟的任务,并且希望在 ScheduledThreadPoolExecutor 队列中只有一个任务。我的想法是使用 getQueue().isEmpty() 来检查队列中是否只有一个任
我如何将参数传递给 ScheduledThreadPoolExecutor? 我有以下代码。您会注意到,我声明了一个变量“num”,并将其作为参数传递给 exampleFunction()。 exam
假设我有这样的方法 public void scheduleCleanup(String parameter) { final SomeObject someObject = new Some
我知道由于各种原因我必须使用它而不是 java.util.Timer。所以,为了研究这个,我正在查看文档,我有几个问题: scheduleWithFixedDelay() 是如何工作的? 我的理解是:
例程 myProcessToRun() 需要执行 100 次,但每次执行之间需要大约一秒钟的延迟。 以下 FOR 循环与 ScheduledThreadPoolExecutor 对象结合使用。 for
ScheduledThreadPoolExecutor 中有两个属性具有以下 getter(以及随附的 setter) : boolean getContinueExistingPeriodicTas
这个问题只是为了对这些概念有一些想法,以了解业内人士将其用于什么目的。 如果您可以仅给出一些示例用法,我将不胜感激。我知道它们是如何工作的,并确实阅读了有关它们的google文档,但我似乎仍然很难选择
所有可用的 ScheduledThreadPoolExecutor 构造函数都需要一个 corePoolsize 参数。但我不确定我实际需要多少? 我计划在一个类中使用它,其中一个实例仅使用 1 个计
我正在尝试在 scala play 框架中实现预定作业。 以下是我的代码: def subCron = { val task = new Runnable { def run() = {
ScheduledThreadPoolExecutor 的文档说 -安排在完全相同执行时间的任务以先进先出 (FIFO) 的提交顺序启用。 这是否意味着应该同时完成的任务永远不会同时完成。相反,它们以
我有这个简单的代码片段: /** * @param args the command line arguments */ public static void main(String[] args
我写了下面的代码: import java.util.Calendar; import java.util.concurrent.ScheduledThreadPoolExecutor; import
如果我使用ThreadPoolExecutor,我有多种构造函数,我可以为池的工作队列传递/使用我自己的队列。 现在我看到 ScheduledThreadPoolExecutor 是 ThreadPo
我正在阅读 ScheduledThreadPoolExecutor JavaDoc并遇到了以下事情: Delayed tasks execute no sooner than they are ena
我是一名优秀的程序员,十分优秀!