这本书的第一版包含了一个简单工作队列的代码[Bloch01,49项)。这个类允许客户端通过后台线程为异步处理排队。当不再需要工作队列时,客户机可以调用一个方法,要求后台线程在完成队列上的任何工作后优雅地终止自己。个实现只不过是一个玩具,但即便如此,它也需要一整页微妙、微妙的代码,如果你做得不对,就很容易出现安全和活性失败。幸运的是,没有理由再编写这种代码了。
当这本书的第二版出版时,java.util.concurrent已经添加到Java中。这个包包含一个Executor框架,它是一个灵活的基于接口的任务执行工具。创建一个工作队列,在任何方面都比在这本书的第一版更好,只需要一行代码:
ExecutorService exec = Executors.newSingleThreadExecutor();
下面是如何提交一个可运行的执行:
exec.execute(runnable);
下面是如何告诉执行器优雅地终止(如果你做不到这一点,你的虚拟机很可能不会退出):
exec.shutdown();
您可以使用executor service做更多的事情。例如,您可以等待特定的任务完成(使用get方法,如第319页第79项所示),您可以等待任何或所有任务集合完成(使用invokeAny或invokeAll方法),您可以等待executor服务终止(使用awaitterminate方法),您可以在任务完成时一个一个地检索它们的结果(使用ExecutorCompletionService),您可以安排任务在特定的时间运行或定期运行(使用
ScheduledThreadPoolExecutor),等等。
如果希望多个线程处理来自队列的请求,只需调用一个不同的静态工厂,该工厂创建一种称为线程池的不同类型的执行器服务。您可以使用固定或可变数量的线程创建线程池。java.util.concurrent.Executors类包含静态工厂,这些工厂提供了您需要的大多数执行器。然而,如果你想要一些不同寻常的,您可以直接使用ThreadPoolExecutor类。这个类允许您配置线程池操作的几乎每个方面。
为特定的应用程序选择executor服务可能比较棘手。对于小程序或负载较轻的服务器,Executors.newCachedThreadPool通常是一个不错的选择,因为它不需要配置,而且通常“做正确的事情”。但是对于负载沉重的生产服务器来说,缓存的线程池不是一个好的选择!在缓存的线程池中,提交的任务不会排队,而是立即传递给线程执行。如果没有可用的线程,则创建一个新的线程。如果服务器负载过重,所有cpu都被充分利用,并且有更多的任务到达,就会创建更多的线程,这只会使情况变得更糟。因此,在负载沉重的生产服务器中,最好使用executor.newFixedThreadPool,它为您提供一个线程数量固定的池,或者直接使用ThreadPoolExecutor类来实现最大限度的控制。
您不仅应该避免编写自己的工作队列,而且通常还应该避免直接使用线程.当您直接使用线程时,线程既是工作单元,又是执行它的机制。在executor框架中,工作单元和执行机制是分开的。关键的抽象是工作单元,即任务。
有两种任务:Runnable和它的近亲Callable(与Runnable类似,只是它返回一个值并可以抛出任意异常)。执行任务的一般机制是executor service。如果您从任务的角度考虑问题,并让executor服务为您执行这些任务,那么您就可以灵活地选择合适的执行策略来满足您的需求,并在您的需求发生变化时更改策略。本质上,Executor框架执行的功能与Collections框架聚合的功能相同。
在Java 7中,Executor框架被扩展为支持fork-join任务,它们由一种特殊的执行器服务(称为fork-join池)运行。一个 fork-join任务,由一个ForkJoinTask实例表示,可以分解为更小的子任务,以及包含fork join池的线程不仅仅是进程 这些任务只是互相“窃取”任务,以确保所有线程都保持不变繁忙,导致更高的CPU利用率、更高的吞吐量和更低的延迟。编写和调优fork-join任务非常棘手。并行流(item48 )是在fork连接池之上编写的,假设它们适合当前的任务,那么您可以轻松地利用它们的性能优势。
对Executor框架的完整处理超出了本书的范围,但是感兴趣的读者可以在 Java Concurrency in Practice接触Java并发[Goetz06]。
本文写于2019.7.23,历时1天