常見線程池 newScheduledThreadPool 定時執行任務的線程池 簡單介紹

一  定時任務

package com.aaa.threaddemo;

import static java.util.concurrent.TimeUnit.NANOSECONDS;

import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledFuture;
import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import javax.xml.crypto.Data;

/*
 * 一 newScheduledThreadPool 是個啥？
 *         1 是一個線程池
 *         2 可定時執行任務
 *         3 核心線程數是固定的
 *         4 非核心線程數 2147483647
 * 
 * 
     public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize) {
        return new ScheduledThreadPoolExecutor(corePoolSize);
    }
    
    public ScheduledThreadPoolExecutor(int corePoolSize) {
        super(
        corePoolSize, 
        Integer.MAX_VALUE, 
        0,        //非核心線程的生存時間是 0 馬上回收。
        NANOSECONDS,
        new DelayedWorkQueue());  //一個優先級的隊列      阻塞的隊列，因為它實現了BlockingQueue
        
    }    
    
   DelayedWorkQueue() 優先級隊列怎么用的？
        隊列一般都是先進先出的，但是在定時/延時任務中，我們需要的是延遲時間短的任務先執行。
        為了解決這個問題，需要用到一種特殊的隊列            
        【優先級隊列】
            對插入的數據進行優先級的排序，保證優先級高的數據先執行。和往隊列中插入的順序無關。
            沒能深入調查。。。。
    
    
  二  提供了兩個方法可以用
  
          schedule(command, delay, unit)
          
          schedule(
          task,                  需要執行的任務
          3,                       間隔的時間
          TimeUnit.SECONDS    時間單位   秒 分 時 。。。
 );
      
        scheduleAtFixedRate(
        command,
        initialDelay,         初次執行 間隔的時間
        period,              再次執行的相隔時間
        unit                 時間的單位
)
    【注意！】
        如果只有一次間隔時間，線程結束后關閉線程池即可。      schedule(command, delay, unit)
        但是當有二次間隔時間，是不能將線程池 shutdown的！   scheduleAtFixedRate(command, initialDelay, period, unit)
         
       
 * 
 */
public class ScheduledThreadPoolDemo {
    public static void main(String[] args) {    
        Integer integer = new Integer(0);
        int maxValue = integer.MAX_VALUE;
        System.out.println("[Integer.MAX_VALUE] = " + maxValue);
        
        SimpleDateFormat df2 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");  //驗證是否是在三秒后執行
        System.out.println(df2.format(System.currentTimeMillis()));  
        
        ExecutorService scheduledPool = Executors.newScheduledThreadPool(1);  //創建定時的線程池 核心數量 2
        ScheduledThreadDemo thread = new ScheduledThreadDemo();    
        
        Runnable task2 = new Runnable() {
            public void run() {
                System.out.println("開啟任務 task2");
            }
        };
        
        ((ScheduledExecutorService) scheduledPool).schedule(thread,3,TimeUnit.SECONDS);        //1.對於thread  2. 延遲時間3后執行任務 3.單位TimeUnit.SECONDS 是 【秒】 三秒后執行
        ((ScheduledExecutorService) scheduledPool).schedule(task2,5,TimeUnit.SECONDS);        //延遲5秒后執行任務  
        
        scheduledPool.shutdown();
    }
}

class ScheduledThreadDemo extends Thread{
    @Override
    public void run() {
        SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");  
        System.out.println(df.format(System.currentTimeMillis()));  
        System.out.println("我是線程1， 我在運行");
        System.out.println("正在運行的線程名字" + Thread.currentThread().getName());
    }
    
}

 

看結果

 

 

 

二  scheduleAtFixedRate ？

package com.aaa.threaddemo;

import static java.util.concurrent.TimeUnit.NANOSECONDS;

import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledFuture;
import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import javax.xml.crypto.Data;

/*
 * 一 newScheduledThreadPool 是個啥？
 *         1 是一個線程池
 *         2 可定時執行任務
 *         3 核心線程數是固定的
 *         4 非核心線程數 2147483647
 * 
 * 
     public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize) {
        return new ScheduledThreadPoolExecutor(corePoolSize);
    }
    
    public ScheduledThreadPoolExecutor(int corePoolSize) {
        super(
        corePoolSize, 
        Integer.MAX_VALUE, 
        0,        //非核心線程的生存時間是 0 馬上回收。
        NANOSECONDS,
        new DelayedWorkQueue());  //一個優先級的隊列      阻塞的隊列，因為它實現了BlockingQueue
        
    }    
    
   DelayedWorkQueue() 優先級隊列怎么用的？
        隊列一般都是先進先出的，但是在定時/延時任務中，我們需要的是延遲時間短的任務先執行。
        為了解決這個問題，需要用到一種特殊的隊列            
        【優先級隊列】
            對插入的數據進行優先級的排序，保證優先級高的數據先執行。和往隊列中插入的順序無關。
            沒能深入調查。。。。
    
    
  二  提供了兩個方法可以用
  
          schedule(command, delay, unit)
          
          schedule(
          task,                  需要執行的任務
          3,                       間隔的時間
          TimeUnit.SECONDS    時間單位   秒 分 時 。。。
 );
      
        scheduleAtFixedRate(
        command,
        initialDelay,         初次執行 間隔的時間
        period,              再次執行的相隔時間
        unit                 時間的單位
)
    【注意！】
        如果只有一次間隔時間，線程結束后關閉線程池即可。      schedule(command, delay, unit)
        但是當有二次間隔時間，是不能將線程池 shutdown的！   scheduleAtFixedRate(command, initialDelay, period, unit)
         
       
 * 
 */
public class ScheduledThreadPoolDemo {
    public static void main(String[] args) {    
        SimpleDateFormat df2 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");  //驗證是否是在三秒后執行
        System.out.println(df2.format(System.currentTimeMillis()));  
        
        ExecutorService scheduledPool = Executors.newScheduledThreadPool(1);  //創建定時的線程池 核心數量 2
        ScheduledThreadDemo thread = new ScheduledThreadDemo();    
        
        Runnable task2 = new Runnable() {
            public void run() {
                System.out.println("開啟任務 task2");
            }
        };
        
        Runnable task3 = new Runnable() {
            public void run() {
                System.out.println("開啟任務 task3");
            }
        };
        
        ((ScheduledExecutorService) scheduledPool).schedule(thread,3,TimeUnit.SECONDS);        //1.對於thread  2. 延遲時間3后執行任務 3.單位TimeUnit.SECONDS 是 【秒】 三秒后執行
        ((ScheduledExecutorService) scheduledPool).schedule(task2,5,TimeUnit.SECONDS);        //延遲5秒后執行任務  
        
        ((ScheduledExecutorService) scheduledPool).scheduleAtFixedRate(task3, 8, 3, TimeUnit.SECONDS);  //對於task3 程序啟動 8秒后執行，中間間隔3秒執行一次。
        
//        scheduledPool.shutdown();
    }
}

class ScheduledThreadDemo extends Thread{
    @Override
    public void run() {
        SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");  
        System.out.println(df.format(System.currentTimeMillis()));  
        System.out.println("我是線程1， 我在運行");
        System.out.println("正在運行的線程名字" + Thread.currentThread().getName());
    }
    
}

 

 

查看結果