多线程应用:定时器

Posted Rocksta

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了多线程应用:定时器相关的知识,希望对你有一定的参考价值。

 一. 定时器

定时器(定时任务)

  • 定时器是一种控制任务延时调用,或者周期调用的技术。
  • 作用:闹钟、定时邮件发送。

定时器的实现方式

  • 方式一:Timer
  • 方式二:ScheduledExecutorService

二. Timer定时器

  • TimerTask继承了Runnable:所以TimerTask是线程任务类 

 

 2.1 Timer定时器的实现

package com.gch.d8_timer;

import java.util.Date;
import java.util.Timer;
import java.util.TimerTask;

/**
   目标:Timer定时器的使用和了解
 */
public class TimerDemo1 
    public static void main(String[] args) 
        // 1.创建Timer定时器
        Timer timer = new Timer(); // 定时器本身就是一个单线程。
        // 2.调用方法,处理定时任务
        timer.schedule(new TimerTask() 
            @Override
            public void run()  // 由定时器线程来调的
                System.out.println(Thread.currentThread().getName() + "执行一次!" 
+ new Date().toLocaleString());
              // 第一次执行 / 启动后首先延迟两秒执行,然后每隔三秒执行一次
        ,2000,3000);
    

 2.2 Timer定时器的特点和存在的问题

  1. 问题1:Timer是单线程,处理多个任务按照顺序执行,存在延时与设置定时器的时间有出入
  • 因为Timer是单线程,某些任务忙,其他任务受到干扰,因为其他任务要等它处理完才执行,比如这里,A,B都是每隔两秒执行一次,但是执行到A的时候线程休眠了5秒,导致B已经过了2s的执行周期但因为线程在休眠无法执行,只能线程过了5s休眠才执行B
package com.gch.d8_timer;

import java.util.Date;
import java.util.Timer;
import java.util.TimerTask;

/**
   目标:Timer定时器存在的问题
   问题1:Timer是单线程,处理多个任务按照顺序执行,存在延时与设置定时器的时间有出入
   因为Timer是单线程,某些任务忙,其他任务受到干扰,因为其他任务要等它处理完才执行
   比如这里,A,B都是每隔两秒执行一次,但是执行到A的时候线程休眠了5秒,导致B已经过了2s的执行周期但因为线程在休眠无法执行,只能线程过了5s休眠才执行B
 */
public class TimerDemo2 
    public static void main(String[] args) 
        // 1.创建Timer定时器
        Timer timer = new Timer(); // 定时器本身就是一个单线程。
        // 2.调用方法,处理定时任务
        timer.schedule(new TimerTask() 
            @Override
            public void run() 
                System.out.println(Thread.currentThread().getName() + "执行A!" + new Date().toLocaleString());
                try 
                    Thread.sleep(5000);
                 catch (InterruptedException e) 
                    throw new RuntimeException(e);
                
             // 启动后直接执行,然后每隔两秒执行一次
        ,0,2000);

        timer.schedule(new TimerTask() 
            @Override
            public void run() 
                System.out.println(Thread.currentThread().getName() + "执行B!" + new Date().toLocaleString());
            
        ,0,2000);
    

问题二:可能因为其中的某个任务的异常使Timer线程死掉,从而影响后续任务执行。

  • 比如这个程序要执行A,B,C三个任务,但是执行到B的时候程序出现异常,导致Timer线程直接挂掉,影响C的执行,导致整个任务全部挂掉。
package com.gch.d8_timer;

import java.util.Date;
import java.util.Timer;
import java.util.TimerTask;

/**
   Timer定时器存在的问题
   问题二:可能因为其中的某个任务的异常使Timer线程死掉,从而影响后续任务执行。
   比如这个程序要执行A,B,C三个任务,但是执行到B的时候程序出现异常,导致Timer线程直接挂掉,影响C的执行
 */
public class TimerDemo3 
    public static void main(String[] args) 
        // 1.创建Timer定时器
        Timer timer = new Timer(); // 定时器本身就是一个单线程。
        // 2.调用方法,处理定时任务
        timer.schedule(new TimerTask() 
            @Override
            public void run() 
                System.out.println(Thread.currentThread().getName() + "执行A!" + new Date().toLocaleString());
             // 启动后直接执行,然后每隔两秒执行一次
        ,0,2000);

        timer.schedule(new TimerTask() 
            @Override
            public void run() 
                System.out.println(Thread.currentThread().getName() + "执行B!" + new Date().toLocaleString());
                System.out.println(10 / 0); // 出现算术异常,Timer线程直接挂掉,影响后续任务执行
            
        ,0,2000);

        timer.schedule(new TimerTask() 
            @Override
            public void run() 
                System.out.println(Thread.currentThread().getName() + "执行C!" + new Date().toLocaleString());
            
        ,0,3000);

    

  •  结论:开发中一般不会去用Timer做定时器!

三. ScheduledExecutorService定时器

  • ScheduledExecutorService它可以用多个线程去处理多个任务,这样即使某一个线程挂掉了也不会影响其他线程的执行。
  • 线程池必然是高级的。

package com.gch.d8_timer;

import java.util.Date;
import java.util.TimerTask;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

/**
 * 目标:ScheduledExecutorService定时器的了解与使用
 */
public class ScheduledExecutorServiceDemo4 
    public static void main(String[] args) 
        // 1.创建ScheduledExecutorService线程池,做定时器
        ScheduledExecutorService pool = Executors.newScheduledThreadPool(3);

        // 2.开启定时任务
        // 以固定速率来执行
        pool.scheduleAtFixedRate(new TimerTask() 
            @Override
            public void run() 
                System.out.println(Thread.currentThread().getName() + "执行输出A   " + new Date().toLocaleString());
                try 
                    Thread.sleep(10000);
                 catch (InterruptedException e) 
                    e.printStackTrace();
                
            
        ,0,2000, TimeUnit.MILLISECONDS);

        pool.scheduleAtFixedRate(new TimerTask() 
            @Override
            public void run() 
                System.out.println(10 / 0); // 有异常,B不执行
                System.out.println(Thread.currentThread().getName() + "执行输出B   " + new Date().toLocaleString());
            
        ,0,2000, TimeUnit.MILLISECONDS);


        pool.scheduleAtFixedRate(new TimerTask() 
            @Override
            public void run() 
                System.out.println(Thread.currentThread().getName() + "执行输出C   " + new Date().toLocaleString());
            
        ,0,2000, TimeUnit.MILLISECONDS);
    

以上是关于多线程应用:定时器的主要内容,如果未能解决你的问题,请参考以下文章

关于JVM案例分析

java-多线程

JVM内存模型详细介绍

JVM内存模型 三

Java技术-0

Java多线程开发的实际应用场景