JAVA并发框架视频之Executor

随着当今处理器中可用的核心数量的增加，随着对实现更高吞吐量的需求的不断增长，多线程API变得非常流行。Java提供了自己的多线程框架，称为Executor框架.

1.Executor框架是什么？

Executor框架包含一组用于有效管理工作线程的组件。Executor API通过Executors将任务的执行与要执行的实际任务解耦。这是生产者-消费者模式的一种实现。

java.util.concurrent.Executors提供了用于创建工作线程的线程池的工厂方法。

为了使用Executor框架，我们需要创建一个线程池并提交任务给它以供执行。Executor框架的工作是调度和执行已提交的任务并从线程池中拿到返回的结果。

浮现于脑海中的一个基本的问题是，当我们创建java.lang.Thread的对象或调用实现了Runnable/Callable接口来达到的程序的并行性时，为什么需要线程池？

答案来源于两个基本面：

为新任务创建新的线程会存在额外的线程创建以及销毁的开销。管理这些线程的生命周期会明显增加CPU的执行时间。

不进行任何限制地为每个进程创建线程会导致创建大量线程。这些线程会占用大量内存并引起资源的浪费。当一个线程利用完CPU的时间片后另一个线程即将利用CPU的时间片时，CPU会花费大量的时间来切换线程的上下文。

所有的这些因素都会导致系统的吞吐量下降。线程池通过保持线程一直存活并重用这些线程来克服这个问题。当提交到线程池中的任务多于正在执行的线程时，那些多余的任务将被放到队列中。一旦执行任务的线程有空闲的了，它们会从队列中取下一个任务来执行。对于JDK提供的现成的executors此任务队列基本是无界的。

2.Executors的类型

现在我们已经了解了executors是什么，让我们来看看不同类型的executors。

2.1 SingleThreadExecutor

此线程池executor只有一个线程。它用于以顺序方式的形式执行任务。如果此线程在执行任务时因异常而挂掉，则会创建一个新线程来替换此线程，后续任务将在新线程中执行。

ExecutorService executorService=Executors.newSingleThreadExecutor()

2.2 FixedThreadPool(n)

顾名思义，它是一个拥有固定数量线程的线程池。提交给executor的任务由固定的n个线程执行，如果有更多的任务，它们存储在LinkedBlockingQueue里。这个数字n通常跟底层处理器支持的线程总数有关。

ExecutorService executorService=Executors.newFixedThreadPool(4);

2.3 CachedThreadPool

该线程池主要用于执行大量短期并行任务的场景。与固定线程池不同，此线程池的线程数不受限制。如果所有的线程都在忙于执行任务并且又有新的任务到来了，这个线程池将创建一个新的线程并将其提交到executor。只要其中一个线程变为空闲，它就会执行新的任务。如果一个线程有60秒的时间都是空闲的，它们将被结束生命周期并从缓存中删除。

但是，如果管理得不合理，或者任务不是很短的，则线程池将包含大量的活动线程。这可能导致资源紊乱并因此导致性能下降。

ExecutorService executorService=Executors.newCachedThreadPool();

2.4 ScheduledExecutor

当我们有一个需要定期运行的任务或者我们希望延迟某个任务时，就会使用此类型的executor。

ScheduledExecutorService scheduledExecService=Executors.newScheduledThreadPool(1);

可以使用scheduleAtFixedRate或scheduleWithFixedDelay在ScheduledExecutor中定期的执行任务。

scheduledExecService.scheduleAtFixedRate(Runnable command,long initialDelay,long period,TimeUnit unit)

scheduledExecService.scheduleWithFixedDelay(Runnable command,long initialDelay,long period,TimeUnit unit)

这两种方法的主要区别在于它们对连续执行定期任务之间的延迟的应答。

scheduleAtFixedRate：无论前一个任务何时结束，都以固定间隔执行任务。

scheduleWithFixedDelay：只有在当前任务完成后才会启动延迟倒计时。

以上就是极悦java培训机构的小编针对“JAVA并发框架视频之Executor”的内容进行的回答，希望对大家有所帮助，如有疑问，请在线咨询，有专业老师随时为你服务。