上一篇中我们看到了Timer的不足之处,本篇我们将围绕这些不足之处看看ScheduledThreadPoolExecutor是如何优化的。
为了研究方便我们需要两个类:
public class Task1 implements Callable<String> {
@Override
public String call() throws Exception {
String base = "abcdefghijklmnopqrstuvwxyz0123456789";
Random random = new Random();
StringBuffer sb = new StringBuffer();
for (int i = 0; i < 10; i++) {
int number = random.nextInt(base.length());
sb.append(base.charAt(number));
}
System.out.println("Task1 running: " + new Date());
return sb.toString();
}
}
生成含有10个字符的字符串,使用Callable接口目的是我们不再任务中直接输出结果,而主动取获取任务的结果
public class LongTask implements Callable<String> {
@Override
public String call() throws Exception {
System.out.println("LongTask running: "+new Date());
TimeUnit.SECONDS.sleep(10);
return "success";
}
}
长任务类,这里我们让任务沉睡10秒然后返回一个“success”
下面我们来分析一下ScheduledThreadPoolExecutor:
1、Timer中单线程问题是否在ScheduledThreadPoolExecutor中存在?
我们先来看一下面的程序:
public class ScheduledThreadPoolExec {
public static void main(String[] args) throws InterruptedException,
ExecutionException {
ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(
2);
ScheduledFuture future1 = executor.schedule(new Task1(), 5,
TimeUnit.SECONDS);
ScheduledFuture future2 = executor.schedule(new LongTask(), 3,
TimeUnit.SECONDS);
BlockingQueue<ScheduledFuture> blockingQueue = new ArrayBlockingQueue<ScheduledFuture>(
2, true);
blockingQueue.add(future2);
blockingQueue.add(future1);
System.out.println(new Date());
while (!blockingQueue.isEmpty()) {
ScheduledFuture future = blockingQueue.poll();
if (!future.isDone())
blockingQueue.add(future);
else
System.out.println(future.get());
}
System.out.println(new Date());
executor.shutdown();
}
}
首先,我们定义了一个ScheduledThreadPoolExecutor它的池长度是2。接着提交了两个任务:第一个任务将延迟5秒执行,第二个任务将延迟3秒执行。我们建立了一个BlockingQueue,用它来存储了ScheduledFuture,使用ScheduledFuture可以获得任务的执行结果。在一个while循环中,我们每次将一个ScheduledFuture从队列中弹出,验证它是否被执行,如果没有被执行则再次将它加入队列中,如果被执行了,这使用ScheduledFuture的get方法获取任务执行的结果。看一下执行结果:
Thu Apr 21 19:23:02 CST 2011
LongTask running: Thu Apr 21 19:23:05 CST 2011
Task1 running: Thu Apr 21 19:23:07 CST 2011
h1o2wd942e
success
Thu Apr 21 19:23:15 CST 2011
我们看到长任务先运行,因为长任务只等待了3秒,然后是输出字符串的任务运行,两个任务开始时间相差2秒,而先输出了字符串而后才是长任务运行的结果success,最后我们查看一下整体的开始和结束时间相差了13秒。
这说明在ScheduledThreadPoolExecutor中它不是以一个线程运行任务的,而是以多个线程,如果用一个线程运行任务,那么长任务运行完之前是不会运行输出字符串任务的。其实这个“多个任务“是我们自己指定的注意一下标红的代码,如果我们把这行代码改为:
ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(1);
那么运行结果就会发生变化,
Thu Apr 21 19:36:56 CST 2011
LongTask running: Thu Apr 21 19:36:59 CST 2011
success
Task1 running: Thu Apr 21 19:37:09 CST 2011
y981iqd0or
Thu Apr 21 19:37:09 CST 2011
这时其实和使用Timer运行结果是一样的。任务是在一个线程里顺序执行的。
2、Timer中一但有运行时异常报出后续任务是否还会正常运行?
为了研究这个问题,我们还是需要一个能够抛出异常的任务,如下:
public class TimerExceptionTask extends TimerTask {
@Override
public void run() {
System.out.println("TimerExceptionTask: "+new Date());
throw new RuntimeException();
}
}
我们对上面运行任务的代码做一点点小小的修改,先运行两个抛出异常的任务,如下:
public class ScheduledThreadPoolExec {
public static void main(String[] args) throws InterruptedException,
ExecutionException {
ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(
2);
ScheduledFuture future1 = executor.schedule(new Task1(), 5,
TimeUnit.SECONDS);
ScheduledFuture future2 = executor.schedule(new LongTask(), 3,
TimeUnit.SECONDS);
executor.schedule(new TimerExceptionTask(), 1, TimeUnit.SECONDS);
executor.schedule(new TimerExceptionTask(), 2, TimeUnit.SECONDS);
BlockingQueue<ScheduledFuture> blockingQueue = new ArrayBlockingQueue<ScheduledFuture>(
2, true);
blockingQueue.add(future2);
blockingQueue.add(future1);
System.out.println(new Date());
while (!blockingQueue.isEmpty()) {
ScheduledFuture future = blockingQueue.poll();
if (!future.isDone())
blockingQueue.add(future);
else
System.out.println(future.get());
}
System.out.println(new Date());
executor.shutdown();
}
}
注意,标红的代码,如果这两个代码抛出错误后会影响后续任务,那么就应该在此终止,但是看一下结果,
Thu Apr 21 19:40:15 CST 2011
TimerExceptionTask: Thu Apr 21 19:40:16 CST 2011
TimerExceptionTask: Thu Apr 21 19:40:17 CST 2011
LongTask running: Thu Apr 21 19:40:18 CST 2011
Task1 running: Thu Apr 21 19:40:20 CST 2011
v5gcf01iiz
success
Thu Apr 21 19:40:28 CST 2011
后续任务仍然执行,可能会有朋友说:“你上面的池设置的是2,所以很有可能是那两个抛出异常的任务都在同一个线程中执行,而另一个线程执行了后续的任务”。那我们就把ScheduledThreadPoolExecutor设置成1看看,结果如下:
Thu Apr 21 19:43:00 CST 2011
TimerExceptionTask: Thu Apr 21 19:43:01 CST 2011
TimerExceptionTask: Thu Apr 21 19:43:02 CST 2011
LongTask running: Thu Apr 21 19:43:03 CST 2011
success
Task1 running: Thu Apr 21 19:43:13 CST 2011
33kgv8onnd
Thu Apr 21 19:43:13 CST 2011
后续任务也执行了,所以说ScheduledThreadPoolExecutor不会像Timer那样有线程泄漏现象。
对于周期性执行和Timer很类似这里就不再举例了。
分享到:
相关推荐
一个高可用的,专门针对定时任务的分布式任务调度框架-niubi-job
界面采用bootstrap和JEasyUI技术实现,提供三种任务运行规则:一次性、周期性、自定义 1、一次性(i:立即运行;ii:在规定的时间刻运行) 2、周期性(i:按小时;ii:按天 iii:按周; iv:按月(日);v: 按月(星期) ...
spring整合quartz动态定时任务demo-spring-quartz-demo
js爬虫,MySQL,定时任务book-crawler-mysql-cron-master.zip
该demo只是实现定时监听、周期性执行任务的功能,而邮件发送、文件删除等自定义功能需要自行添加上去,只需在run方法下修改邮件发送、文件删除等功能即可;
分布式定时任务库 distributed-cron
定时任务相关技术实操-timed-task-practice
thinkphp 5.1 定时任务,Crontab 计划任务-think-cron
一款支持自定义定时任务的chatgpt-on-wechat插件-timetask
go 语言实现的分布式定时任务调度器-bee-crontab
ELK数据报表定时任务管理平台,定时任务统计上报应用性能指标-kibana-eye
Spring Task+Zookeeper分布式定时任务调度组件-Taroco-Scheduler
linux 计划任务cron--教你怎么定时执行的指令
1_什么事定时任务.mp4 2_为什么学习定时任务.mp4 3_定时任务技术发展趋势.mp4 4_主流定时任务框架优缺点和什么是分布式定时任务.mp4 5_环境搭建总体流程.mp4 6_前期准备-JDK.mp4 7_前期准备-Maven.mp4 8_前期准备-...
定时启动任务--跟随web容器启动,定时启动任务--跟随web容器启动
定时任务管理带WEB管理界面-quartz-web
kratos定时任务-kratos-cron
实现可定时响起的闹钟----PendingIntent 与 AlarmManager 的运用
将要定时访问的 链接 放到 cron.php 中 对应位置 运行代码即可。...使用里面的 _sock 方法非阻塞运行 如果进程死掉了 在触发时 会根据 cron.log 的文件... linux 系统建议使用 crontab 定时任务,window建议使用计划任务。
Job Plus项目是基于SpringBoot+Vue的轻量级定时任务管理系统-job-plus