我用这行代码创建了一个 ThreadPoolExecutor :
private ExecutorService executor = new ThreadPoolExecutor(5, 10, 120, TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(20, true));
然后,我运行 25 个任务(T01 到 T25)所以情况是:
- 当前正在运行 5 个任务(T01 到 T05)
- 20 个任务在队列中等待(T06 到 T25)
当我再放置 1 个任务 (T26) 时,由于队列已满,我希望旧任务 (T06) 被删除以启动(因为未达到 MaxPoolSize),新任务 (T26) 被放置在队列的末尾。
但在现实生活中,如果 Queue 已满且未达到 MaxPoolSize,则会启动最新任务。
所以,我有...
- 当前正在运行 6 个任务(T01 到 T05 和 T26)
- 20 个任务在队列中等待(T06 到 T25)
...而不是...
- 当前正在运行 6 个任务(T01 到 T06)
- 20 个任务在队列中等待(T07 到 T26)
我可以配置 ThreadPoolExecutor 以获得预期的结果吗? 我应该使用其他类(class)吗?
有关ThreadPoolExecutor部分源码的信息
public void execute(Runnable command) {
if (command == null)
throw new NullPointerException();
if (poolSize >= corePoolSize || !addIfUnderCorePoolSize(command)) {
if (runState == RUNNING && workQueue.offer(command)) {
if (runState != RUNNING || poolSize == 0)
ensureQueuedTaskHandled(command);
}
else if (!addIfUnderMaximumPoolSize(command))
reject(command); // is shutdown or saturated
}
}
private boolean addIfUnderMaximumPoolSize(Runnable firstTask) {
Thread t = null;
final ReentrantLock mainLock = this.mainLock;
mainLock.lock();
try {
if (poolSize < maximumPoolSize && runState == RUNNING)
t = addThread(firstTask);
} finally {
mainLock.unlock();
}
if (t == null)
return false;
t.start();
return true;
}
谢谢
最佳答案
我会让核心大小等于最大值。这就是大多数池的使用方式,我不确定您的情况何时会出现不利情况,但您会按顺序执行任务。
关于java - 如何保证 ThreadPoolExecutor 中的 FIFO 执行顺序,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/4431128/