的ThreadPoolExecutor：它是怎样重用线程

Question

，我读了ThreadPoolExecutor拥有的线程池，该池是注定要降低创造新线程的成本（至少我理解这样的方式如下短语）：

当你发送任务给执行程序，它会尝试使用池线程 来执行此任务，以避免连续产生 线程。 [Java 7的并发菜谱]

但，因为我知道我们有没有办法重新启动线程Java编写的。

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

Answer 1

这非常简单 - 实质上是Thread的睡眠，等待被任务唤醒 - 他们运行该任务，然后再次入睡。

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而它是空的。当我添加一个项目时，当前被阻止的Thread（s）被唤醒，并且一个将执行任务（LinkedBlockingDeque是线程安全的）。当Thread完成任务后，它会重新进入睡眠状态。

JavaDoc对于ThreadPoolExecutor描述了详细的逻辑。 ThreadPoolExecutor的所有构造函数都采用BlockingQueue<Runnable> - 这应该给您提示逻辑如何工作的提示。

注意：这不等于忙等待。 A BlockingQueue使用wait和notify暂停和唤醒Thread s，这意味着池中的Thread在未处理任务时没有做任何工作。由于Thread会阻止所有CPU核心的轮询，从而不允许程序继续进行（或者至少严重损害它），所以基于等待的忙碌方法将不起作用。