这么说吧,java线程池的实现原理其实很简单 (2)

这么说吧,java线程池的实现原理其实很简单

初始化的线程池中只有一个线程,如果该线程异常结束,会重新创建一个新的线程继续执行任务,唯一的线程可以保证所提交任务的顺序执行,内部使用LinkedBlockingQueue作为阻塞队列。

newScheduledThreadPool

这么说吧,java线程池的实现原理其实很简单

初始化的线程池可以在指定的时间内周期性的执行所提交的任务,在实际的业务场景中可以使用该线程池定期的同步数据。

实现原理

除了newScheduledThreadPool的内部实现特殊一点之外,其它几个线程池都是基于ThreadPoolExecutor类实现的。

线程池内部状态

这么说吧,java线程池的实现原理其实很简单

其中AtomicInteger变量ctl的功能非常强大:利用低29位表示线程池中线程数,通过高3位表示线程池的运行状态:

1、RUNNING:-1 << COUNT_BITS,即高3位为111,该状态的线程池会接收新任务,并处理阻塞队列中的任务;

2、SHUTDOWN: 0 << COUNT_BITS,即高3位为000,该状态的线程池不会接收新任务,但会处理阻塞队列中的任务;

3、STOP : 1 << COUNT_BITS,即高3位为001,该状态的线程不会接收新任务,也不会处理阻塞队列中的任务,而且会中断正在运行的任务;

4、TIDYING : 2 << COUNT_BITS,即高3位为010;

5、TERMINATED: 3 << COUNT_BITS,即高3位为011;

任务提交

线程池框架提供了两种方式提交任务,根据不同的业务需求选择不同的方式。

Executor.execute()

这么说吧,java线程池的实现原理其实很简单

通过Executor.execute()方法提交的任务,必须实现Runnable接口,该方式提交的任务不能获取返回值,因此无法判断任务是否执行成功。

ExecutorService.submit()

这么说吧,java线程池的实现原理其实很简单

通过ExecutorService.submit()方法提交的任务,可以获取任务执行完的返回值。

任务执行

当向线程池中提交一个任务,线程池会如何处理该任务?

execute实现

这么说吧,java线程池的实现原理其实很简单

具体的执行流程如下:

1、workerCountOf方法根据ctl的低29位,得到线程池的当前线程数,如果线程数小于corePoolSize,则执行addWorker方法创建新的线程执行任务;否则执行步骤(2);

2、如果线程池处于RUNNING状态,且把提交的任务成功放入阻塞队列中,则执行步骤(3),否则执行步骤(4);

3、再次检查线程池的状态,如果线程池没有RUNNING,且成功从阻塞队列中删除任务,则执行reject方法处理任务;

4、执行addWorker方法创建新的线程执行任务,如果addWoker执行失败,则执行reject方法处理任务;

这么说吧,java线程池的实现原理其实很简单

addWorker实现

从方法execute的实现可以看出:addWorker主要负责创建新的线程并执行任务,代码实现如下:

这么说吧,java线程池的实现原理其实很简单

这只是addWoker方法实现的前半部分:

1、判断线程池的状态,如果线程池的状态值大于或等SHUTDOWN,则不处理提交的任务,直接返回;

2、通过参数core判断当前需要创建的线程是否为核心线程,如果core为true,且当前线程数小于corePoolSize,则跳出循环,开始创建新的线程,具体实现如下:

内容版权声明:除非注明,否则皆为本站原创文章。

转载注明出处:https://www.heiqu.com/zgdjsy.html