threadpoolexecutor中工作线程和工作队列的用途

Question

根据我的理解，ThreadpoolExecitor有两个主要的数据结构（工人，workQueue）用于管理tasks.worker（Set）有线程，这些线程将一直运行到执行器关闭，workerQueue将所有任务保留到执行器。但是根据代码，我没有看到所有任务都被添加到workQ中ueue.task仅在第1361行添加到队列中，不会在每种情况下都执行。

Answer 1

实际上不，workQueue实际上并没有保留提交给执行器的所有任务。这是#执行（Runnable）的主要部分（以此为参考，您可能使用蕨类植物反编译源或不同版本或其他）；

 1323           int c = ctl.get();
 1324           if (workerCountOf(c) < corePoolSize) {
 1325               if (addWorker(command, true))
 1326                   return;
 1327               c = ctl.get();
 1328           }
 1329           if (isRunning(c) && workQueue.offer(command)) {
 1330               int recheck = ctl.get();
 1331               if (! isRunning(recheck) && remove(command))
 1332                   reject(command);
 1333               else if (workerCountOf(recheck) == 0)
 1334                   addWorker(null, false);
 1335           }
 1336           else if (!addWorker(command, false))
 1337               reject(command);

此代码有3个步骤：

1. 检查执行者是否可以添加工作人员。如果可以，请使用新工人

与您的问题相关的案例是第一步，在此步骤中，代码在添加任何内容之前返回。事实上，情况并非如此，Worker的构造函数有一个runnable参数，这是它的第一个任务。每当TPE添加新工作线程时，提交的runnable是该工作线程中运行的第一个任务。如果找到第一个任务，runWorker（Worker）方法将运行该任务，或者等待前面提到的工作队列中出现任务。