java定时线程池_java 定时器线程池(ScheduledThreadPoolExecutor)的实现

前言

定时器线程池提供了定时执行任务的能力,即可以延迟执行,可以周期性执行。但定时器线程池也还是线程池,最底层实现还是ThreadPoolExecutor,可以参考我的另外一篇文章多线程–精通ThreadPoolExecutor。

特点说明

1.构造函数

public ScheduledThreadPoolExecutor(int corePoolSize) {

// 对于其他几个参数在ThreadPoolExecutor中都已经详细分析过了,所以这里,将不再展开

// 这里我们可以看到调用基类中的方法时有个特殊的入参DelayedWorkQueue。

// 同时我们也可以发现这里并没有设置延迟时间、周期等参数入口。

// 所以定时执行的实现必然在DelayedWorkQueue这个对象中了。

super(corePoolSize, Integer.MAX_VALUE, 0, NANOSECONDS,

new DelayedWorkQueue());

}

2.DelayedWorkQueue

DelayedWorkQueue是在ScheduledThreadPoolExecutor的一个内部类,实现了BlockingQueue接口

里面存放任务队列的数组如下:

private RunnableScheduledFuture>[] queue =

new RunnableScheduledFuture>[INITIAL_CAPACITY];

我们分析过ThreadPoolExecutor,它从任务队列中获取任务的方式为poll和take两种,所以看一下poll和take两个方法的源码,回顾一下,ThreadPoolExecutor它会调用poll或take方法,先poll,再take,只要其中一个接口有返回就行

public RunnableScheduledFuture> poll() {

final ReentrantLock lock = this.lock;

lock.lock();

try {

RunnableScheduledFuture> first = queue[0];

// 这里有个getDelay,这是关键点,获取执行延时时间

// 但是如果我们有延时设置的话,这就返回空了,然后就会调用take方法

if (first == null || first.getDelay(NANOSECONDS) > 0)

return null;

else

return finishPoll(first);

} finally {

lock.unlock();

}

}

public RunnableScheduledFuture> take() throws InterruptedException {

final ReentrantLock lock = this.lock;

lock.lockInterruptibly();

try {

for (;;) {

RunnableScheduledFuture> first = queue[0];

if (first == null)

available.await();

else {

// 获取延时时间

long delay = first.getDelay(NANOSECONDS);

if (delay <= 0)

return finishPoll(first);

first = null; // don't retain ref while waiting

if (leader != null)

available.await();

else {

Thread thisThread = Thread.currentThread();

leader = thisThread;

try {

// 使用锁,执行延时等待。

// 使用锁,执行延时等待。

// 使用锁,执行延时等待。

available.awaitNanos(delay);

} finally {

if (leader == thisThread)

leader = null;

}

}

}

}

} finally {

if (leader == null && queue[0] != null)

available.signal();

lock.unlock();

}

}

3.RunnableScheduledFuture

在ScheduledThreadPoolExecutor内部有一个ScheduledFutureTask类实现了RunnableScheduledFuture,ScheduledFutureTask这个类采用了装饰者设计模式,在执行Runnable的方法基础上还执行了一些额外的功能。

我们需要特别注意几个参数period、time。

(1)time

首先看一下time的作用,可以发现time是用于获取执行延时时间的,也就是delay是根据time生成的

public long getDelay(TimeUnit unit) {

return unit.convert(time - now(), NANOSECONDS);

}

(2)period

这个参数不是说设置执行几个周期,而是用于判断是否需要按周期执行,以及执行周期,也就是本次执行与下次执行间隔的时间

// 判断是否需要按周期执行,如果周期设置成0,不是无间隔执行,而是只执行一次,这个需要特别注意

public boolean isPeriodic() {

return period != 0;

}

private void setNextRunTime() {

long p = period;

if (p > 0)

// 这里将周期加给time,这样获取的延迟时间就是周期时间了。

time += p;

else

time = triggerTime(-p);

}

(3)执行

public void run() {

// 先判断是否为周期性的任务

boolean periodic = isPeriodic();

if (!canRunInCurrentRunState(periodic))

cancel(false);

else if (!periodic)

// 如果不是周期性的,就执行调用父类的run方法,也就是构造函数中传入的Runnable对象的run方法。

ScheduledFutureTask.super.run();

// 在if的括号中先执行了任务

else if (ScheduledFutureTask.super.runAndReset()) {

// 如果是周期性的,就需要设置下次执行的时间,然后利用reExecutePeriodic方法,将任务再次丢入任务队列中。

// 这里尤其需要注意的是if中的逻辑执行失败,如果没有捕捉异常,那么后面的逻辑就不会再执行了,也就是说中间有一次执行失败,后面这个周期性的任务就失效了。

setNextRunTime();

reExecutePeriodic(outerTask);

}

}

总结

ScheduledThreadPoolExecutor通过time参数,设置当前任务执行的等待时间,再通过period设置任务下次执行需要等待的时间。这两个参数都不是设置在线程池中的,而是携带在任务中的,这就可以把线程池和任务进行完全解耦。

注意点:

(1)任务的执行等待时间是在队列的take方法中的。

(2)period参数设置成0,任务将只会执行一次,而不会执行多次

(3)如果要自己实现周期性Task,周期性任务在执行过程中,一定要注意捕捉异常,否则某一次执行失败,将导致后续的任务周期失效,任务将不再继续执行。

到此这篇关于java 定时器线程池(ScheduledThreadPoolExecutor)的实现的文章就介绍到这了,更多相关java 定时器线程池内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/272851.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

iOS 关于关键字高亮

- (NSMutableAttributedString *)colorStr: (NSString *)originalStr // originalStr : 需要高亮传入的字符串 { NSMutableAttributedString *dataStr [[[NSMutableAttributedString alloc] initWithString:originalStr] autorelease]; for (int i 0; i < originalStr.l…

成功,要“借力”,不要“尽力”(深刻!)

01每个人都喜欢成功&#xff0c;却又时常感觉自己力不从心一个小男孩在院子里搬一块石头&#xff0c;父亲在旁边鼓励&#xff1a;“孩子&#xff0c;只要你全力以赴&#xff0c;一定搬得起来&#xff01;”但是石头太重&#xff0c;最终孩子也没能搬起来。他告诉父亲&#xff1…

java 网站开发实例_完整的javaweb项目

【实例简介】主要功能有以下几个&#xff1a;1.用户注册 2.用户登录 3.用户列表展示 4.用户信息修改 5.用户信息删除【实例截图】【核心代码】javaweb└── javaweb├── src│ └── com│ ├── dao│ │ ├── UserDaoImpl.java│ │ └── UserDao.java│…

Nginx+Php-fpm+MySQL+Redis源码编译安装指南

说明&#xff1a;本教程由三部分组成如下&#xff1a; 1. 源码编译安装Nginx 2. 源码编译安装php以及mysql、redis扩展模块 3. 配置虚拟主机 文中所涉及安装包程序均提供下载链接&#xff0c;欢迎使用 执行环境以及前置条件&#xff1a;Ubuntu 12.04 LTS 已安装…

NetFramework各个版本的特性笔记

我的博客&#xff1a;http://www.cnblogs.com/hgmyz/p/6916064.html公式记忆&#xff1a;.Net 2.0CLRBCLC#(VB.Net)Win FormWeb Form.Net 3.0.Net 2.0WCFWPFWFWCS.Net 3.5.Net 3.0Asp.Net AjaxSliverlightLinq.Net 4.0 增加了并行的支持&#xff0c;与旧的Framwork并行工作。默…

从0开始学Java——JSPServlet——HttpServletRequest相关的几个路径信息

在HttpServletRequest中有几个获取路径的接口&#xff1a;getRequestURI/getContextPath/getServletPath/getPathInfo 这些接口互相之间有什么区别&#xff0c;通过下面这段代码就可以分辨清楚了&#xff1a; 1 WebServlet("/hello.view")2 public class FirstServle…

C#编译和运行过程图例

一张图&#xff0c;描述C#编译和运行过程&#xff0c;比较容易记忆理解

java 不重启部署_编译Java类后不重启Tomcat有两种方式:热部署、热加载

不重启Tomcat有两种方式&#xff1a;热部署、热加载热部署&#xff1a;容器状况在运行时重新部署整个项目。这类环境下一般整个内存会清空,重新加载&#xff0c;这类方式有可能会造成sessin丢失等环境。tomcat 6确实可以热部署了,而且对话也没丢.热加载&#xff1a;最好是在调试…

修改mysql的用户密码

修改的用户都以root为列。一、拥有原来的myql的root的密码&#xff1b; 方法一&#xff1a; #mysql -u root mysql> SET PASSWORD FOR rootlocalhost PASSWORD(newpass); 方法二&#xff1a;在mysql系统外&#xff0c;使用mysqladmin# mysqladmin -u root -p password &quo…

C#中的堆和栈理解

引言&#xff1a;程序运行时&#xff0c;它的数据必须存在内存中&#xff0c;一个数据需要多大内存、存储在什么地方以及如何存储都依赖于该数据的数据类型。1、什么是栈栈是一个内存数组&#xff0c;是一个LIFO&#xff08;Last-In-First-Out 后进先出&#xff09;的数据结构。…

java sessionmanager_java.lang.IllegalStateException:没有SessionManager

你错过了3件事.Main.javaimport org.eclipse.jetty.server.Server;import org.eclipse.jetty.server.handler.ContextHandler;import org.eclipse.jetty.server.session.HashSessionIdManager;import org.eclipse.jetty.server.session.HashSessionManager;import org.eclipse.…

什么是链表

链表是一种物理存储单元上非连续、非顺序的存储结构&#xff0c;数据元素的逻辑顺序是通过链表中的指针链接次序实现的。链表由一系列结点&#xff08;链表中每一个元素称为结点&#xff09;组成&#xff0c;结点可以在运行时动态生成。每个结点包括两个部分&#xff1a;一个是…

C# 基础:Sealed、new、virtual、abstract、override的理解

目录 1、sealed 2、new 3、virtual 4、abstract 5、override 1、sealed 密封类不能被继承&#xff0c;密封方法可以重写基类中的方法&#xff0c;但其本身不能在任何派生类&#xff08;子类&#xff09;中 进一步重写。当应用于属性或者方法时&#xff0c;sealed 修饰符必须始终…

梁兴珍 java_数据结构与算法_Java语言

第1章 综述1.1 数据结构和算法能起到什么作用&#xff1f;1.2 数据结构的概述1.3 算法的概述1.4 一些定义1.5 面向对象编程1.6 软件工程1.7 对于C程序员的Java1.8 Java数据结构的类库第2章 数组2.1 Array专题Applet2.2 Java中数组的基础知识2.3 将程序划分成类2.4 类接口2.5 Or…

Yii 2.0: yii2-highcharts-widget创建饼状图

安装 The preferred way to install this extension is through composer. 项目根目录下执行&#xff1a; php composer.phar require --prefer-dist miloschuman/yii2-highcharts-widget "*"或者在composer.json中添加 "miloschuman/yii2-highcharts-widget&qu…

【原创】C#中的抽象类(abstract class)和接口(interface)的比较

在C#中抽象类和接口是两个相当重要的概念&#xff0c;深入理解对C#程序员是非常必要的&#xff0c;现总结如下&#xff1a;一、抽象类的特点&#xff1a;1、抽象方法只用于方法的声明并不包含方法的实现&#xff0c;可以看作没有实现实体的虚方法。2、抽象类不能进行实例化。3、…

U3D 脚本添加和获得对象

有时候&#xff0c;一开始可能没有对象&#xff0c;而是由于某种触发&#xff0c;产生的一个对象&#xff0c;这里讲解下&#xff0c;如何通过脚本来创建一个对象&#xff1a; 这是通过脚本创建一个立方体&#xff1a; using UnityEngine; using System.Collections;public cla…

50条超精辟的经典语录:哗众,可以取宠,也可以失宠!

在人生道路上给自己定位很重要&#xff0c;不要苛求自己达到不可能达到的高度。我们能把每一件平凡的事做好就是不平凡&#xff0c;把每一件简单的事做成功就是不简单。1.我们只有一个地球&#xff0c;所以你要爱护地球&#xff1b;地球上只有一个我&#xff0c;所以你也要爱护…

java 时间工具类 大于_Java 时间工具类

1 /**2 * 格式化字符串为日期格式3 *4 *paramdateStr 需要格式化的字符串5 *paramformat 需要的日期格式&#xff0c;例如"yyyy-MM-dd HH:mm:ss"6 *return7 */8 public staticDate formatDate(String dateStr, String format) {9 SimpleDateFormat dateFormat newSi…

IP、TCP和DNS与HTTP的密切关系

看了上一篇博文的发表时间&#xff0c;是7月22日&#xff0c;现在是10月22日&#xff0c;已经有三个月没写博客了。这三个月里各种忙各种瞎折腾&#xff0c;发生了很多事情&#xff0c;也思考了很多问题。现在这段时间开始闲下来了&#xff0c;同时该思考的事情也思考清楚了&am…