Java并发框架:Executor API详解
介绍
随着当今处理器中可用的核心数量的增加，随着对实现更高吞吐量的需求的不断增长，多线程API变得非常流行。Java提供了自己的多线程框架，称为Executor框架.
1.Executor框架是什么？
Executor框架包含一组用于有效管理工作线程的组件。ExecutorAPI通过Executors将任务的执行与要执行的实际任务解耦。这是生产者-消费者模式的一种实现。
java.util.concurrent.Executors提供了用于创建工作线程的线程池的工厂方法。
为了使用Executor框架，我们需要创建一个线程池并提交任务给它以供执行。Executor框架的工作是调度和执行已提交的任务并从线程池中拿到返回的结果。
浮现于脑海中的一个基本的问题是，当我们创建java.lang.Thread的对象或调用实现了Runnable/Callable接口来达到的程序的并行性时，为什么需要线程池？
答案来源于两个基本面：
- 为新任务创建新的线程会存在额外的线程创建以及销毁的开销。管理这些线程的生命周期会明显增加CPU的执行时间。
- 不进行任何限制地为每个进程创建线程会导致创建大量线程。这些线程会占用大量内存并引起资源的浪费。当一个线程利用完CPU的时间片后另一个线程即将利用CPU的时间片时，CPU会花费大量的时间来切换线程的上下文。
所有的这些因素都会导致系统的吞吐量下降。线程池通过保持线程一直存活并重用这些线程来克服这个问题。当提交到线程池中的任务多于正在执行的线程时，那些多余的任务将被放到队列中。一旦执行任务的线程有空闲的了，它们会从队列中取下一个任务来执行。对于JDK提供的现成的executors此任务队列基本是无界的。
2.Executors的类型
现在我们已经了解了executors是什么，让我们来看看不同类型的executors。
2.1SingleThreadExecutor
此线程池executor只有一个线程。它用于以顺序方式的形式执行任务。如果此线程在执行任务时因异常而挂掉，则会创建一个新线程来替换此线程，后续任务将在新线程中执行。
ExecutorServiceexecutorService=Executors.newSingleThreadExecutor()
2.2FixedThreadPool(n)
顾名思义，它是一个拥有固定数量线程的线程池。提交给executor的任务由固定的n个线程执行，如果有更多的任务，它们存储在LinkedBlockingQueue里。这个数字n通常跟底层处理器支持的线程总数有关。
ExecutorServiceexecutorService=Executors.newFixedThreadPool(4);
2.3CachedThreadPool
该线程池主要用于执行大量短期并行任务的场景。与固定线程池不同，此线程池的线程数不受限制。如果所有的线程都在忙于执行任务并且又有新的任务到来了，这个线程池将创建一个新的线程并将其提交到executor。只要其中一个线程变为空闲，它就会执行新的任务。如果一个线程有60秒的时间都是空闲的，它们将被结束生命周期并从缓存中删除。
但是，如果管理得不合理，或者任务不是很短的，则线程池将包含大量的活动线程。这可能导致资源紊乱并因此导致性能下降。
ExecutorServiceexecutorService=Executors.newCachedThreadPool();
2.4ScheduledExecutor
当我们有一个需要定期运行的任务或者我们希望延迟某个任务时，就会使用此类型的executor。
ScheduledExecutorServicescheduledExecService=Executors.newScheduledThreadPool(1);
可以使用scheduleAtFixedRate或scheduleWithFixedDelay在ScheduledExecutor中定期的执行任务。
scheduledExecService.scheduleAtFixedRate(Runnablecommand,longinitialDelay,longperiod,TimeUnitunit)
scheduledExecService.scheduleWithFixedDelay(Runnablecommand,longinitialDelay,longperiod,TimeUnitunit)
这两种方法的主要区别在于它们对连续执行定期任务之间的延迟的应答。
- scheduleAtFixedRate：无论前一个任务何时结束，都以固定间隔执行任务。
- scheduleWithFixedDelay：只有在当前任务完成后才会启动延迟倒计时。
3.对于Future对象的理解
可以使用executor返回的java.util.concurrent.Future对象访问提交给executor的任务的结果。Future可以被认为是executor对调用者的响应。
Futureresult=executorService.submit(callableTask);
如上所述，提交给executor的任务是异步的，即程序不会等待当前任务执行完成，而是直接进入下一步。相反，每当任务执行完成时，executor在此Future对象中设置它。
调用者可以继续执行主程序，当需要提交任务的结果时，他可以在这个Future对象上调用.get()方法来获取。如果任务完成，结果将立即返回给调用者，否则调用者将被阻塞，直到executor完成此操作的执行并计算出结果。
如果调用者不能无限期地等待任务执行的结果，那么这个等待时间也可以设置为定时地。可以通过Future.get(longtimeout，TimeUnitunit)方法实现，如果在规定的时间范围内没有返回结果，则抛出TimeoutException。调用者可以处理此异常并继续执行该程序。
如果在执行任务时出现异常，则对get方法的调用将抛出一个ExecutionException。
对于Future.get()方法返回的结果，一个重要的事情是，只有提交的任务实现了java.util.concurrent.Callable接口时才返回Future。如果任务实现了Runnable接口，那么一旦任务完成，对.get()方法的调用将返回null。
另一个关注点是Future.cancel(booleanmayInterruptIfRunning)方法。此方法用于取消已提交任务的执行。如果任务已在执行，则executor将尝试在mayInterruptIfRunning标志为true时中断任务执行。
4.Example:创建和执行一个简单的Executor
我们现在将创建一个任务并尝试在fixedpoolexecutor中执行它：
publicclassTaskimplementsCallable{ privateStringmessage; publicTask(Stringmessage){ this.message=message; } @Override publicStringcall()throwsException{ return"Hello"+message+"!"; } }
Task类实现Callable接口并有一个String类型作为返回值的方法。这个方法也可以抛出Exception。这种向executor抛出异常的能力以及executor将此异常返回给调用者的能力非常重要，因为它有助于调用者知道任务执行的状态。
现在让我们来执行一下这个任务：
publicclassExecutorExample{
publicstaticvoidmain(String[]args){
Tasktask=newTask("World");
ExecutorServiceexecutorService=Executors.newFixedThreadPool(4);
Futureresult=executorService.submit(task);
try{
System.out.println(result.get());
}catch(InterruptedException|ExecutionExceptione){
System.out.println("Erroroccuredwhileexecutingthesubmittedtask");
e.printStackTrace();
}
executorService.shutdown();
}
}
我们创建了一个具有4个线程数的FixedThreadPoolexecutors，因为这个demo是在四核处理器上开发的。如果正在执行的任务执行大量I/O操作或花费较长时间等待外部资源，则线程数可能超过处理器的核心数。
我们实例化了Task类，并将它提交给executors执行。结果由Future对象返回，然后我们在屏幕上打印。
让我们运行ExecutorExample并查看其输出：
HelloWorld!
正如所料，任务追加了问候语Hello并通过Futureobject返回结果。
最后，我们调用executorService对象上的shutdown来终止所有线程并将资源返回给OS。
.shutdown()方法等待executor完成当前提交的任务。但是，如果要求是立即关闭executor而不等待，那么我们可以使用.shutdownNow()方法。
任何待执行的任务都将结果返回到java.util.List对象中。
我们也可以通过实现Runnable接口来创建同样的任务：
publicclassTaskimplementsRunnable{
privateStringmessage;
publicTask(Stringmessage){
this.message=message;
}
publicvoidrun(){
System.out.println("Hello"+message+"!");
}
}
当我们实现Runnable时，这里有一些重要的变化。
无法从run()方法得到任务执行的结果。因此，我们直接在这里打印。
run()方法不可抛出任何已受检的异常。
5.总结
随着处理器时钟速度难以提高，多线程正变得越来越主流。但是，由于涉及复杂性，处理每个线程的生命周期非常困难。
在本文中，我们展示了一个高效而简单的多线程框架，即ExecutorFramework，并解释了它的不同组件。我们还看了一下在executor中创建提交和执行任务的不同示例。
与往常一样，此示例的代码可以在GitHub上找到。
英文原文：https://stackabuse.com/concurrency-in-java-the-executor-framework/