温馨提示×

温馨提示×

您好,登录后才能下订单哦!

密码登录×
登录注册×
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》

Java中Executor的使用方法

发布时间:2021-07-13 09:21:59 来源:亿速云 阅读:107 作者:chen 栏目:大数据

本篇内容介绍了“Java中Executor的使用方法”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!

在上一篇我们简单的介绍了线程池的使用,虽然线程池比我们直接使用原始的线程类更加方便,但在创建线程池对象时对参数的设置是需要开发人员精心考量的,否则线程池并不会实现我们满意的效果。在实际的开发中,我们用的最多的线程框架其实不是线程池而是Executor。它为我们创建一个线程池提供了更方便的方法。Executor是一个接口,它是Executor框架的基础,它使任务的提交与任务的执行分离。底层仍然使用的是线程池。通过Executor框架的工具类Executors,可以创建3种类型的线程池它们分别是:FixedThreadPool、SingleThreadExecutor、CachedThreadPool。下面我们分别看一下它们之间的区别。

FixedThreadPool:可重用固定线程数的线程池。

Java中Executor的使用方法

我们从源码中可以看出newFixedThreadPool()方法将线程池中的初始化的线程数和允许最大的线程数都设置成了参数值。也就是说我们参数传递的是多少就同时有多少个线程在同时执行。并且它又创建了LinkedBlockingQueue来实现线程池中的队列服务。我们知道LinkedBlockingQueue是一个无界队列,也就是说它可以存储很多个线程任务,当线程池中的并发任务大于线程池中允许的最大数时,就会将任务保存到此队列中。当有线程执行完毕后,线程池在从队列中取出相应的任务去执行。并且我发们发现newFixedThreadPool()方法中已经将keepAliveTime设置为0,目的是如果有线程执行完任务后,要求立即终止。

SingleThreadExecutor:单个线程的线程池。

Java中Executor的使用方法

我们看出SingleThreadExecutor()和newFixedThreadPool()方法几乎一样,只是设置了线程池的初始化线程数和允许的最大线程数都是1。执行的过程和上诉的逻辑一样。

CachedThreadPool:根据需要创建新线程的线程池。

Java中Executor的使用方法

我们看CachedThreadPool()将corePool设置为0,把maximumPoolSize设置最Integer.MAX_VALUE。意思是在创建这个线程池时,没有初始化空闲线程,而是如果有任务添加,那么它就会创建一个新线程。

下面我们看一下具体的代码。

FixedThreadPool

Java中Executor的使用方法

Java中Executor的使用方法

因为我们只创建了2个线程,所以这个线程池的最大并发数就是2,所以任务一任务二是先同时输出的,任务三是后输出的。因为任务三被添加到了队列中,只有其它任务执行完,才会执行队列中的任务。

SingleThreadExecutor

Java中Executor的使用方法

Java中Executor的使用方法

Java中Executor的使用方法

因为SingleThreadExecutor线程池最大的并发数是1,所以当我们提交3个任务时,只有一个会执行另外两个会被添加到队列中,所以执行的结果显示只有一个线程。

CachedThreadPool

Java中Executor的使用方法

Java中Executor的使用方法

Java中Executor的使用方法

我们知道CachedThreadPool线程池中初始化的空闲线程是0,但是它允许的最大线程数是Integer.MAX_VALUE也就相当于无限大。所以我们在提交任务时,因为没有超过允许的最大线程数所以线程池就会为我们创建一个新线程。所以任务一任务二任务三都是并行执行的。

“Java中Executor的使用方法”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识可以关注亿速云网站,小编将为大家输出更多高质量的实用文章!

向AI问一下细节

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

AI