如何保证 ThreadPoolExecutor 中的 FIFO 执行顺序

我用这行代码创建一个 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未达到，newest任务开始。

所以我有 ...

• 当前正在运行 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;
}

Thanks

我会让核心尺寸等于最大值。这就是大多数池的使用方式，我不确定在您的情况下什么时候会出现缺点，但您会按顺序执行任务。