任务调度(四)——ScheduledExecutorService替代Timer,实现多线程任务调度

简介:        上篇博文《任务调度(三)——Timer的替代品ScheduledExecutorService简介》已经对ScheduledExecutorService做了简单介绍,其实使用ScheduledExecutorService来替代Timer也是迫不得已的事情。

       上篇博文《任务调度(三)——Timer的替代品ScheduledExecutorService简介》已经对ScheduledExecutorService做了简单介绍,其实使用ScheduledExecutorService来替代Timer也是迫不得已的事情。主要原因如下:

  1. Timer不支持多线程,所有挂在Timer下的任务都是单线程的,任务只能串行执行,如果其中一个任务执行时间过长,会影响到其他任务的执行,然后就可能会有各种接踵而来的问题。
  2. Timer的线程不捕获异常,TimerTask如果抛出异常,那么Timer唯一的进程就会挂掉,这样挂在Timer下的所有任务都会无法继续执行。

       第一个问题,随着业务数据的猛增,我们生产上有几个任务现在每次执行需要1-3个小时,在这段时间内,该timer下的其他任务只能等待,这是让人无法忍受的。重开一个Timer?难道要为所有的耗时的Task都单开一个Timer,显然是不太可能,这样就太乱了。


       第二个问题,是极其致命的。好多业务数据都是晚上的定时任务跑出来的,结果由于程序的问题或者内存资源不足,导致线程被kill了。该timer下的所有任务都未执行,结果第二天整整忙活了一天,主要任务就是——跑任务,调整数据。深受其害呀!


       为了弥补Timer的缺陷,jdk1.5中引入了并发包,这里面提供的ScheduledExecutorService。具体实现类是:ScheduledThreadPoolExecutor。ScheduledThreadPoolExecutor支持多线程,同时在线程中对异常进行了捕获。所以是Timer的完美替换者。


       分享一个实例吧:

/** 
 * task2
 * @author arron
 * @date 2015年8月5日 下午2:08:34 
 * @version 1.0 
 */
public class Task2 extends TimerTask{

	@SuppressWarnings("deprecation")
	@Override
	public void run() {
		System.out.println("----task2 start--------"+new Date().toLocaleString());
		try {
			Thread.sleep(5000);
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
		System.out.println("----5s later, task2 end--------"+new Date().toLocaleString());
	}
}
       测试代码:
	public static void main(String[] args) {

		ScheduledExecutorService pool = Executors.newScheduledThreadPool(2);//启用2个线程
		
		Task1 t1 = new Task1();
		// 立即执行,任务消耗3秒,执行结束后等待2秒,【有空余线程时】,再次执行该任务
		pool.scheduleWithFixedDelay(t1, 0, 2, TimeUnit.SECONDS);
		
		// 立即执行,任务消耗5秒,执行结束后等待2秒,【有空余线程时】,再次执行该任务
		Task2 t2 = new Task2();
		pool.scheduleWithFixedDelay(t2, 0, 2, TimeUnit.SECONDS);
		
	}
       执行结果如图:



       这样任务之间就不会相互影响了,而且可以同时执行。但是线程数量要设置好了。过渡增加线程数也会适得其反。

目录
相关文章
|
6月前
多线程(初阶八:计时器Timer)
多线程(初阶八:计时器Timer)
103 0
|
1月前
|
安全 Java
【多线程-从零开始-拾】Timer-定时器
【多线程-从零开始-拾】Timer-定时器
28 0
|
6月前
|
缓存 监控 Java
Java并发编程:线程池与任务调度
【4月更文挑战第16天】Java并发编程中,线程池和任务调度是核心概念,能提升系统性能和响应速度。线程池通过重用线程减少创建销毁开销,如`ThreadPoolExecutor`和`ScheduledThreadPoolExecutor`。任务调度允许立即或延迟执行任务,具有灵活性。最佳实践包括合理配置线程池大小、避免过度使用线程、及时关闭线程池和处理异常。掌握这些能有效管理并发任务,避免性能瓶颈。
54 0
|
算法 Java Go
【多线程系列-03】深入理解java中线程的生命周期,任务调度
【多线程系列-03】深入理解java中线程的生命周期,任务调度
175 0
|
6月前
|
Java
【Java多线程】定时器Timer
【Java多线程】定时器Timer
51 0
【Java多线程】定时器Timer
|
Java 调度
ScheduledExecutorService:多线程任务调度
ScheduledExecutorService:多线程任务调度
776 0
ScheduledExecutorService:多线程任务调度
|
druid 关系型数据库 MySQL
高并发下 MySQL Statement Cancellation Timer 的线程数暴涨
高并发下 MySQL Statement Cancellation Timer 的线程数暴涨
【JavaEE】多线程之定时器(Timer)
【JavaEE】多线程之定时器(Timer)
|
安全 Java
【Java|多线程与高并发】定时器(Timer)详解
在Java中,定时器Timer类是用于执行定时任务的工具类。它允许你安排一个任务在未来的某个时间点执行,或者以固定的时间间隔重复执行。
|
Java 调度
任务调度线程池
任务调度线程池