Java线程池使用与原理

线程池是什么?

我们可以利用java很容易创建一个新线程,同时操作系统创建一个线程也是一笔不小的开销。所以基于线程的复用,就提出了线程池的概念,我们使用线程池创建出若干个线程,执行完一个任务后,该线程会存在一段时间(用户可以设定空闲线程的存活时间,后面会介绍),等到新任务来的时候就直接复用这个空闲线程,这样就省去了创建、销毁线程损耗。当然空闲线程也会是一种资源的浪费(所有才有空闲线程存活时间的限制),但总比频繁的创建销毁线程好太多。 下面是我的测试代码

使用线程池5w线程运行完大约为400ms,不使用线程池运行大约为4350ms左右,其效率可见一斑(读者可以自行测试,不过由于电脑配置不一样,跑出来的数据会有差别,但使用线程池绝对是比创建线程要快的)。

java如何使用线程池?

上面的测试代码中已经使用了线程池,下面正式介绍一下。

java所有的线程池最顶层是一个Executor接口,其只有一个execute方法,用于执行所有的任务,java又提供了ExecutorService接口继承自Executor并且扩充了一下方法,在往下就是AbstractExecutorService这个抽象类,其实现了ExecutorService,最后就是ThreadPoolExecutor其继承自上面的抽象类,我们常使用的java线程池就是创建的这个类的实例。

而上面我们使用Executors是一个工具类,它就是一个语法糖,为我们把各种不同的业务的线程池参数进行封装,进行new操作。

上面就是Executors.newFixedThreadPool(10)的源码。

下面重点来了,说一说ThreadPoolExecutor构造方法各参数的意思。

上面这个构造方法是最全的。

下面我们根据源码来解释部分参数意思,这样更有说服力。

下面是ThreadPoolExecutor#execute方法,就是我们上面接口调用的execute实际执行者。

ctl是一个AtomicInteger实例,是一个提供了原子语句的CAS操作的类,它用来记录线程池中当前运行的线程数量加上-2^29,workCountOf方法就取得其绝对值(可以去看源码如何实现),当其小于corePoolSize时,会调用addWorker方法(是用来创建一个新Workder,Workder会创建一个Thread,所以就是创建线程的方法),addWorkd创建线程过程中会跟corePoolSize或者maxnumPoolSize的值比较(当传入true会根corePoolSize比较,false会根据maxnumPoolSize比较,大于等于其值会创建失败)。可见如何当前运行中的线程数量小于corePoolSize就是创建并且也会创建成功( 只简单的讨论线程池Running状态下)。

如果当运行中线程数大于等于corePoolSize时,进入第二个if,isRunning是跟SHUTDOWN(其值=0)比较,之前说过c等于当前运行的线程数量加上-2^29,如果当前当前运行的线程数据达到2^29时其值就=0,isRunning返回false,else中在执行addWorkd也会返回false(addWorkd也对其进行了检验),所以这表示线程池最多能支持2^29个线程同时运行(足够用了)。

workQueue.offer(command)就是将runnable加入等待队列,加入等待队列后runWorker方法会从队列中获取任务执行的。如果当前队列采用的是有界队列(ArrayBlockingQueue)当队列满了offer就会返回false,这是就进入else if,看!这里传入了false,说明这里要跟maxnumPoolSize比较了,如果这里运行的线程数大于等于maxnumPoolSize,那么这个线程任务就要被线程池拒绝了,执行reject(command),拒绝方法中使用了我们ThreadPoolExecutor构造方法中的RejectedExecutionHandler(拒绝策略),后面再详细解释。

经过上面的结合源码的介绍,下面对们ThreadPoolExecutor的参数介绍就好理解了。

线程池中线程创建和拒绝策略

corePoolSize,maxnumPoolSize,BlockingQueue这三个要一块说

当线程池运行的线程小于corePoolSize时,来一个新线程任务总是会新建一个线程来执行;当大于corePoolSize就会把任务加入到等待队列blockingQueue中,如果你传入的BlockingQueue是一个无界队列(LinkedBlockingQueue)这是队列可以存放“无穷多”的任务,所有总是会加入队列成功,跟maxnumPoolSize就没关系了,这也表示线程池中线程数最多为corePoolSize个;但是如果你传入的是有界队列(ArrayBlockingQueue,SynchronousQueue),当队列满时,并且线程数小于maxmunPoolSize就是创建新的线程直至线程数大于maxnumPoolSize;如果当线程数量大于maxnumPoolSize时,在加入任务就会被线程池拒绝。

RejectedExecutionHandler拒绝策略java给实现了4个AbortPolicy,CallerRunsPolicy,DiscardOldestPolicy,DiscardPolicy用户也可以自己实现该接口实现自己的拒绝策略;第一个就是直接抛出异常,我们可以进行trycatch处理;第二个就是该新任务直接运行;第三个是取消队列中最老的;第四个是取消当前任务。


原文发布于微信公众号 - JAVA烂猪皮(gp1106701116)

原文发表时间:2018-05-28

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏码匠的流水账

java取消线程实例

调用interrupt并不意味着立即停止目标线程正在进行的工作,而只是传递了请求中断的消息。对中断操作的正确理解是:它并不会真正地中断一个正在运行的线程,而只是...

9620
来自专栏Java技术栈

史上最全 Java 多线程面试题及答案

这些多线程的问题,有些来源于各大网站、有些来源于自己的思考。可能有些问题网上有、可能有些问题对应的答案也有、也可能有些各位网友也都看过,但是本文写作的重心就是所...

8810
来自专栏我是攻城师

理解Java并发工具包线程池的设计

创建线程的流程依赖底层的操作系统,不同的操作系统可能不一样,此外更多的线程意味着 OS调度需要做更多的工作来决定哪一个线程可以访问资源,并且要通过OS调度切换维...

16120
来自专栏微信公众号:Java团长

40个Java多线程问题总结

这些多线程的问题,有些来源于各大网站、有些来源于自己的思考。可能有些问题网上有、可能有些问题对应的答案也有、也可能有些各位网友也都看过,但是本文写作的重心就是所...

15430
来自专栏Java架构师历程

40个Java多线程问题总结

java多线程分类中写了21篇多线程的文章,21篇文章的内容很多,个人认为,学习,内容越多、越杂的知识,越需要进行深刻的总结,这样才能记忆深刻,将知识变成自己的...

16030
来自专栏架构师小秘圈

40个多线程问题总结

作者:五月的仓颉 来自:cnblogs.com/xrq730/p/5060921.html ? 1、多线程有什么用? 一个可能在很多人看来很扯淡的一个问题:我会...

40170
来自专栏ImportSource

Java 并发编程系列: CountDownLatch (上厕所的案例)

1、What is CountDownLatch? CountDownLatch提供了一种同步机制,可以允许一个或多个线程等待,直到其他线程上的一系列操作完成后...

30160
来自专栏Java帮帮-微信公众号-技术文章全总结

Java并发学习3【面试+工作】

ReadWriteLock是jdk5中提供的读写分离锁。读写分离锁可以有效的帮助减少锁竞争,以提升性能。用锁分离的机制来提升性能非常容易理解,比如线程A1,A2...

15240
来自专栏芋道源码1024

【死磕Java并发】—- J.U.C之并发工具类:CyclicBarrier

此篇博客所有源码均来自JDK 1.8 CyclicBarrier,一个同步辅助类,在API中是这么介绍的: 它允许一组线程互相等待,直到到达某个公共屏障点 (c...

34940
来自专栏chenssy

【死磕Java并发】—–J.U.C之并发工具类:CyclicBarrier

CyclicBarrier,一个同步辅助类,在API中是这么介绍的: 它允许一组线程互相等待,直到到达某个公共屏障点 (common barrier point...

34940

扫码关注云+社区

领取腾讯云代金券