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

【问题标题】：How to guarantee FIFO execution order in a ThreadPoolExecutor如何保证 ThreadPoolExecutor 中的 FIFO 执行顺序
【发布时间】：2010-12-13 16:41:35
【问题描述】：

我用这行代码创建了一个 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;
}

谢谢

【问题讨论】：

标签： java multithreading fifo

【解决方案1】：

我会让核心大小等于最大值。这就是大多数池的使用方式，我不确定您的情况何时会不利，但您会按顺序执行任务。

【讨论】：

我必须同意这里。最坏的情况是你有 5 个空闲线程，它们无论如何都会被挂起，所以不会发生上下文切换。
好的，但这有点令人沮丧-：P ThreadPoolExecutor 正是我需要的，除了不是保证的FIFO 顺序。这个想法是尽可能地保留 5 个线程，并且仅在需要时才临时重载线程执行器。如果我将 maxPoolSize 设置为 corePoolSize，我将失去临时超载线程执行程序的可能性。无论如何，感谢您的回复:-)
我有一个问题，因为队列是先进先出，如果我有 10 个任务（小于最小/最大核心大小），线程池是否可以按顺序执行。我的意思是，如果我有事情要做，请在 run() 的第一行中使用 printRunInfo()。 printRunInfo 确定是 FIFO 吗？
@Jaskey 如果您有一个线程，它们将按顺序执行。如果您有多个线程，它们将按顺序被拾取，但当它们完成时，即使时间开始它们也可能是无序的
@PeterLawrey ，我发现这个问题非常令人难过，请您回答我的问题以明确原因，并提出解决方案：stackoverflow.com/questions/42153013/… 吗？谢谢！