ThreadPoolExecutor：它如何重用线程

Question

我读到ThreadPoolExecutor有一个线程池，这个池注定要减少创建新线程的成本（至少我这样理解下面的短语）：

当您向执行程序发送任务时，它会尝试使用一个池线程来执行此任务，以避免线程的持续生成。[Java7并发Cookbook]

但是，我知道我们没有办法在Java重启线程。

问题：ThreadPoolExecutor如何避免创建新线程？

Answer 1

这很简单-本质上是线程的睡眠，等待被任务唤醒-他们运行该任务，然后再次睡眠。

public static void main(final String[] args) throws Exception {
    final BlockingQueue<Runnable> blockingQueue = new LinkedBlockingDeque<>();
    final Thread t = new Thread(new Runnable() {

        @Override
        public void run() {
            while (true) {
                try {
                    blockingQueue.take().run();
                } catch (InterruptedException ex) {
                    return;
                }
            }
        }
    });
    t.start();
    blockingQueue.add(new Runnable() {

        @Override
        public void run() {
            System.out.println("Task 1");
        }
    });
    blockingQueue.add(new Runnable() {

        @Override
        public void run() {
            System.out.println("Task 2");
        }
    });
}

BlockingQueue将在线程为空时阻止该线程。当我添加一个项目时，当前被阻止的Thread（s）将被唤醒，其中一个将执行该任务（LinkedBlockingDeque是线程安全的）。当线程完成任务后，它将返回睡眠状态。

ThreadPoolExecator的JavaDoc详细描述了逻辑。ThreadPoolExecator的所有构造函数都需要一个BlockingQueue

注意：这和忙着等待不同。BlockingQueue使用wait和notify来挂起和唤醒线程s，这意味着池中的线程s在不处理任务时没有做任何工作。基于忙等待的方法不起作用，因为线程s将阻塞所有CPU内核，其轮询不允许程序继续（或至少严重损害程序）。