提交给ExecutorService对象的任务的执行顺序是什么？

Question

向ExecutorService对象提交任务的执行顺序是什么？

场景：让我们暂时假设Executor线程池大小为5，我已经向它提交了20个可运行任务，我们知道一次只能执行5个任务，其余的任务将在bucket中等待。所以我的问题是提交的任务以什么顺序执行。它是遵循FIFO数据结构还是从bucket中随机选取任务。

还有，有没有办法指定它应该以什么顺序执行。

例子：

ExecutorService executor = Executors.newFixedThreadPool(5);
for(int i =0; i < 100; i++){
  executor.submit(() -> {
    System.out.println("print task");
  })
}

Answer 1

这取决于线程池和队列的实现。

在ThreadPoolExecitor的情况下，队列几乎总是SynChronousQueue、LinkedBlockingQueue或ArrayBlockingQueue。ArrayBlockingQueue和LinkedBlockingQueue保证FIFO排序。对于SynChronousQueue，它取决于同步机制的FIFO功能，因为SynChronousQueue一次只能保留一个元素。您最好假设它不能保证。

在SchduledThreadPoolExecitor的情况下，队列是DelayQueue。基本上它是一个优先级队列，很可能使用堆数据结构实现。任务将按照延迟的顺序从队列中取出，但不能保证FIFO适用于具有相同延迟的两个任务。

然而，您必须考虑到，毕竟，从队列中选择任务并不意味着它将立即执行，因为线程具有先发制人的性质。执行器的主循环基本上如下所示：

public void run () {
    while(!terminated) {
        Runnable task = queue.take();
        task.run();
    }
}

假设有两个线程正在运行此代码。这种情况可能发生：

1. 线程1：<代码>可运行任务=队列。take（）
2. 线程2：<代码>可运行任务=队列。take（）
3. 线程2：<代码>任务。run（）
4. 线程1：<代码>任务。run（）

瞧，第二个任务在队列中排在后面，但在第一个任务之前执行。实际上，这种情况经常发生。

最后，你不能也不应该假设任何事情。

Answer 2

它使用LinkedBlockingQueue存储挂起的任务。因此，对于挂起的任务，它遵循FIFO顺序。请查找java文档以及方法签名。

/**
     * Creates a thread pool that reuses a fixed number of threads
     * operating off a shared unbounded queue.  At any point, at most
     * {@code nThreads} threads will be active processing tasks.
     * If additional tasks are submitted when all threads are active,
     * they will wait in the queue until a thread is available.
     * If any thread terminates due to a failure during execution
     * prior to shutdown, a new one will take its place if needed to
     * execute subsequent tasks.  The threads in the pool will exist
     * until it is explicitly {@link ExecutorService#shutdown shutdown}.
     *
     * @param nThreads the number of threads in the pool
     * @return the newly created thread pool
     * @throws IllegalArgumentException if {@code nThreads <= 0}
     */

    public static ExecutorService newFixedThreadPool(int nThreads) {
        return new ThreadPoolExecutor(nThreads, nThreads,
                                      0L, TimeUnit.MILLISECONDS,
                                      new LinkedBlockingQueue<Runnable>());
    }