我用这行代码创建了一个 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 以获得预期的结果吗？我应该使用其他课程吗？
有关信息，部分 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;
}
谢谢