线程池之ScheduledThreadPool学习
发布日期:2021-05-06 23:31:56 浏览次数:19 分类:技术文章

本文共 1103 字,大约阅读时间需要 3 分钟。

简介

ScheduledThreadPool是一个能实现定时、周期性任务的线程池。

创建方法

public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize) {
return new ScheduledThreadPoolExecutor(corePoolSize); }

这里创建了ScheduledThreadPoolExecutor,ScheduledThreadPoolExecutor继承自ThreadPoolExecutor,主要用于给定 延时之后的运行任务或定期处理任务。ScheduledThreadPoolExecutor的构造方法如下:

public ScheduledThreadPoolExecutor(int corePoolSize) {
super(corePoolSize, Integer.MAX_VALUE, 0, NANOSECONDS, new DelayedWorkQueue()); }

ScheduledThreadPoolExecutor构造方法中最终调用的是父类ThreadPoolExecutor的构造方法;corePoolSize是传递进来的固定数值,maximumPoolSize的值是Integer.MAX_VALUE;DelayedWorkQueue是无界的,因此maximumPoolSize是无效的。

execute方法执行

在这里插入图片描述当执行ScheduledThreadPoolExecutor的scheduleAtFixedRate或scheduleWithFixedDelay方法,会向DelayedWorkQueue添加一个实现RunnableScheduledFuture接口的任务包装类ScheduledFutureTask,并检查运行的线程是否达到核心线程数corePoolSize。

如果没有就新建线程,并启动。但并非立即执行任务,而是去DelayedWorkQueue中取任务包装类ScheduledFutureTask,然后再去执行任务;
如果运行的线程达到了corePoolSize,就把任务添加到任务队列DelayedWorkQueue中;DelayedWorkQueue会将任务排序,先执行的任务放在队列的前面。
任务执行完后,ScheduledFutureTask中的变量time改为下次要执行的时间,并放回到DelayedWorkQueue中。

上一篇:Java并发之死锁
下一篇:线程池之SingleThreadPool学习

发表评论

最新留言

感谢大佬
[***.8.128.20]2025年04月04日 05时41分11秒