`
sooxin
  • 浏览: 257266 次
  • 性别: Icon_minigender_1
  • 来自: 成都
社区版块
存档分类
最新评论

Java 并发专题 : Timer的缺陷 用ScheduledExecutorService替代

 
阅读更多

1、Timer管理延时任务的缺陷

a、以前在项目中也经常使用定时器,比如每隔一段时间清理项目中的一些垃圾文件,每个一段时间进行数据清洗;然而Timer是存在一些缺陷的,因为Timer在执行定时任务时只会创建一个线程,所以如果存在多个任务,且任务时间过长,超过了两个任务的间隔时间,会发生一些缺陷:下面看例子:

Timer的源码:

 

public class Timer {
    /**
     * The timer task queue.  This data structure is shared with the timer
     * thread.  The timer produces tasks, via its various schedule calls,
     * and the timer thread consumes, executing timer tasks as appropriate,
     * and removing them from the queue when they're obsolete.
     */
    private TaskQueue queue = new TaskQueue();
 
    /**
     * The timer thread.
     */
    private TimerThread thread = new TimerThread(queue);

 

 

TimerThread是Thread的子类,可以看出内部只有一个线程。下面看个例子

package com.zhy.concurrency.timer;
 
import java.util.Timer;
import java.util.TimerTask;
 
public class TimerTest
{
	private static long start;
 
	public static void main(String[] args) throws Exception
	{
 
		TimerTask task1 = new TimerTask()
		{
			@Override
			public void run()
			{
 
				System.out.println("task1 invoked ! "
						+ (System.currentTimeMillis() - start));
				try
				{
					Thread.sleep(3000);
				} catch (InterruptedException e)
				{
					e.printStackTrace();
				}
 
			}
		};
		TimerTask task2 = new TimerTask()
		{
			@Override
			public void run()
			{
				System.out.println("task2 invoked ! "
						+ (System.currentTimeMillis() - start));
			}
		};
		Timer timer = new Timer();
		start = System.currentTimeMillis();
		timer.schedule(task1, 1000);
		timer.schedule(task2, 3000);
 
	}
}

 

定义了两个任务,预计是第一个任务1s后执行,第二个任务3s后执行,但是看运行结果:

task1 invoked ! 1000
task2 invoked ! 4000

 

task2实际上是4后才执行,正因为Timer内部是一个线程,而任务1所需的时间超过了两个任务间的间隔导致。下面使用ScheduledThreadPool解决这个问题:

package com.zhy.concurrency.timer;
 
import java.util.TimerTask;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
 
public class ScheduledThreadPoolExecutorTest
{
	private static long start;
 
	public static void main(String[] args)
	{
		/**
		 * 使用工厂方法初始化一个ScheduledThreadPool
		 */
		ScheduledExecutorService newScheduledThreadPool = Executors
				.newScheduledThreadPool(2);
		
		TimerTask task1 = new TimerTask()
		{
			@Override
			public void run()
			{
				try
				{
 
					System.out.println("task1 invoked ! "
							+ (System.currentTimeMillis() - start));
					Thread.sleep(3000);
				} catch (Exception e)
				{
					e.printStackTrace();
				}
 
			}
		};
 
		TimerTask task2 = new TimerTask()
		{
			@Override
			public void run()
			{
				System.out.println("task2 invoked ! "
						+ (System.currentTimeMillis() - start));
			}
		};
		start = System.currentTimeMillis();
		newScheduledThreadPool.schedule(task1, 1000, TimeUnit.MILLISECONDS);
		newScheduledThreadPool.schedule(task2, 3000, TimeUnit.MILLISECONDS);
	}
}

 输出结果:

task1 invoked ! 1001
task2 invoked ! 3001

 

符合我们的预期结果。因为ScheduledThreadPool内部是个线程池,所以可以支持多个任务并发执行。

 

2、Timer当任务抛出异常时的缺陷

如果TimerTask抛出RuntimeException,Timer会停止所有任务的运行:

package com.zhy.concurrency.timer;
 
import java.util.Date;
import java.util.Timer;
import java.util.TimerTask;
 
 
public class ScheduledThreadPoolDemo01
{
 
 
	public static void main(String[] args) throws InterruptedException
	{
 
		final TimerTask task1 = new TimerTask()
		{
 
			@Override
			public void run()
			{
				throw new RuntimeException();
			}
		};
 
		final TimerTask task2 = new TimerTask()
		{
 
			@Override
			public void run()
			{
				System.out.println("task2 invoked!");
			}
		};
		
		Timer timer = new Timer();
		timer.schedule(task1, 100);
		timer.scheduleAtFixedRate(task2, new Date(), 1000);
		
		
 
	}
}

 

上面有两个任务,任务1抛出一个运行时的异常,任务2周期性的执行某个操作,输出结果:

task2 invoked!
Exception in thread "Timer-0" java.lang.RuntimeException
	at com.zhy.concurrency.timer.ScheduledThreadPoolDemo01$1.run(ScheduledThreadPoolDemo01.java:24)
	at java.util.TimerThread.mainLoop(Timer.java:512)
	at java.util.TimerThread.run(Timer.java:462)

 

由于任务1的一次,任务2也停止运行了。。。下面使用ScheduledExecutorService解决这个问题:

package com.zhy.concurrency.timer;
 
import java.util.Date;
import java.util.Timer;
import java.util.TimerTask;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
 
 
public class ScheduledThreadPoolDemo01
{
 
 
	public static void main(String[] args) throws InterruptedException
	{
 
		final TimerTask task1 = new TimerTask()
		{
 
			@Override
			public void run()
			{
				throw new RuntimeException();
			}
		};
 
		final TimerTask task2 = new TimerTask()
		{
 
			@Override
			public void run()
			{
				System.out.println("task2 invoked!");
			}
		};
		
		
		
		ScheduledExecutorService pool = Executors.newScheduledThreadPool(1);
		pool.schedule(task1, 100, TimeUnit.MILLISECONDS);
		pool.scheduleAtFixedRate(task2, 0 , 1000, TimeUnit.MILLISECONDS);
 
	}
}

 

代码基本一致,但是ScheduledExecutorService可以保证,task1出现异常时,不影响task2的运行:

task2 invoked!
task2 invoked!
task2 invoked!
task2 invoked!
task2 invoked!<span style="font-family: Arial, Helvetica, sans-serif;">...</span>

 

3、Timer执行周期任务时依赖系统时间

 

Timer执行周期任务时依赖系统时间,如果当前系统时间发生变化会出现一些执行上的变化,ScheduledExecutorService基于时间的延迟,不会由于系统时间的改变发生执行变化。

 

上述,基本说明了在以后的开发中尽可能使用ScheduledExecutorService(JDK1.5以后)替代Timer。

分享到:
评论

相关推荐

    Java并发Timer源码分析

    Java并发Timer源码分析 Java并发编程是Java编程中一个非常重要的方面,java.util.Timer是Java中的一个基本组件,用于实现延时和周期...同时,需要注意Timer的缺陷和使用限制,避免因Timer的缺陷而导致的并发编程问题。

    Timer-java.rar_java timer_timer_timer java

    除了`java.util.Timer`,Java 5引入了`java.util.concurrent.ScheduledExecutorService`,它提供了更高级的定时任务调度功能,如精确的定时、定时周期的调整以及更灵活的并发控制。 总结起来,这个项目使用了Java...

    java5定时器java Timer

    这个类是Java早期版本中对定时任务管理的一个重要实现,尽管在Java 5之后,`java.util.concurrent`包中的`ScheduledExecutorService`被推荐使用,但`Timer`仍然在很多场景下被广泛采用。 `Timer`类主要有两个核心...

    java.util.timer实现的简单定时任务

    Java.util.Timer类是Java标准库提供的一种简单但功能有限的定时任务执行机制。它允许开发者在指定的时间间隔或特定时间点执行任务,非常适合处理一次性或周期性的后台操作。本篇文章将深入探讨如何使用Timer和...

    java_Timer_thread.rar_java thread timer_java timer_java 定时器_java

    Java中的定时器(Timer)是Java.util包下用于执行定期任务的一个类,它与线程(Thread)紧密关联,能够帮助开发者实现定时执行特定任务的需求。这个机制在多线程编程(multithreading)中非常有用,特别是在需要定期...

    java定时器(timer类使用详解)

    Java定时器,也被称为`Timer`类,是Java标准库中的一个强大工具,它允许开发者在指定的时间间隔执行任务,从而实现定时操作。这个类在`java.util`包中定义,是实现定时任务调度的核心。在本文中,我们将深入探讨`...

    Benchmark::Timer-开源

    《Benchmark::Timer——Perl中的基准测试利器》 在Perl编程领域,进行性能优化是至关重要的。为了有效地评估和比较代码的执行效率,开发者通常需要一个可靠的基准测试工具。"Benchmark::Timer"就是这样一款强大的...

    《Java编程语言:原理与范例》课后实验源代码.doc

    在Java编程语言中,我们可以看到两个不同的实验,分别涉及到线程和图形用户界面(GUI)的应用。下面将详细解释这两个实验及其涉及的知识点。 实验一: 这个实验展示了一个简单的Java多线程应用,用于实时显示当前...

    服装:服装(多元FunctIonal DaTa中的异常检测):timer_clock::timer_clock::timer_clock::timer_clock::timer_clock::timer_clock::timer_clock::timer_clock::timer_clock::timer_clock::timer_clock::timer_clock::timer_clock::timer_clock::timer_clock::timer_clock:

    全套服装 服装的目标是检测多元功能数据中的异常值安装您可以使用以下命令从安装服装的发行版本: install.packages( " outfit " ) 以及来自的开发版本: # install.packages("devtools")devtools :: install_github...

    java timer定时器详解(附详细代码)

    Java Timer定时器详解 Java Timer定时器是Java语言中的一种常用的定时器机制,它可以帮助开发者实现一些需要在特定时间或...通过使用java.util.Timer和java.util.TimerTask两个类,开发者可以轻松地实现定时器的功能。

    Java定时任务:利用java Timer类实现定时执行任务的功能

    考虑使用`ScheduledExecutorService`替代`Timer`,以获得更好的并发性能和控制。 通过理解`Timer`和`TimerTask`的工作原理以及它们的方法,开发者可以有效地在Java应用程序中实现定时任务,满足各种定时需求。

    几种定时任务(Timer、TimerTask、ScheduledFuture)的退出—结合真实案例【JAVA并发】.docx

    接下来,我们转向ScheduledExecutorService,它是Java并发框架中更现代和强大的定时任务管理工具。ScheduledExecutorService基于ExecutorService,可以调度延迟执行或定期执行的任务。在案例中,使用了Executors....

    java 定时器(Timer)

    Java定时器(Timer)是Java Swing库中的一个类,它提供了调度任务在未来某个时间执行的能力。这个类主要用于在GUI应用程序中实现定时触发某些操作,比如更新界面、执行动画或者执行周期性的后台任务。Timer类结合了...

    Java Timer:schedule和scheduleAtFixedRate

    在Java编程语言中,`java.util.Timer` 类是用于调度任务执行的重要工具。它允许我们按照预定的时间间隔安排任务的执行,或者在特定的未来时间点执行一次或多次任务。本篇文章将深入探讨 `Timer` 类的两个核心方法:`...

    java定时执行代码.

    Java提供了多种实现定时任务的机制,这里主要介绍两种:Java.util.Timer类和java.util.concurrent.ScheduledExecutorService接口。 1. Java.util.Timer类: Timer类是Java早期提供的定时任务工具,它可以安排在...

    STM32_TIMER.rar_STM32入门篇之通用定时器彻底研究_stm32 timerstart_stm32 定时器1_s

    十一个STM32定时器学习程序...TIMER-9 : TIMER2使能TIMER3(时钟都用内部时钟,两个非同步)。 TIMER-10: TIMER2启动TIMER3(时钟都用内部时钟,两个非同步)。 TIMER-11: TIMER4的通道1同时出发TIMER4和TIMER3两个定时器。

    JAVA定时任务调度

    2. **Java并发库:java.util.concurrent.ScheduledExecutorService** `ScheduledExecutorService`是Java并发库的一部分,提供了更灵活的定时任务调度功能。它可以并发执行任务,支持一次性或周期性的任务安排,并且...

    STM32定时器研究

    TIMER-1 : 定时器上溢。... TIMER-9 : TIMER2使能TIMER3(时钟都用内部时钟,两个非同步)。 TIMER-10: TIMER2启动TIMER3(时钟都用内部时钟,两个非同步)。 TIMER-11: TIMER4的通道1同时出发TIMER4和TIMER3两个定时器。

    C#三种定时器实现例子:Timer_Test.rar

    本示例项目“Timer_Test.rar”提供了三种不同类型的定时器的实现:System.Windows.Forms.Timer、System.Timers.Timer和System.Threading.Timer。每种定时器都有其特定的应用场景和特性,下面将详细介绍这三种定时器...

Global site tag (gtag.js) - Google Analytics