定时器线程池（ScheduledThreadPoolExecutor）

Posted 2023-04-30

参考技术A 定时器线程池提供了定时执行任务的能力，即可以延迟执行，可以周期性执行。但定时器线程池也还是线程池，最底层实现还是ThreadPoolExecutor，可以参考我的另外一篇文章 多线程--精通ThreadPoolExecutor 。

DelayedWorkQueue是在ScheduledThreadPoolExecutor的一个内部类，实现了BlockingQueue接口
里面存放任务队列的数组如下：

我们分析过ThreadPoolExecutor，它从任务队列中获取任务的方式为poll和take两种，所以看一下poll和take两个方法的源码，回顾一下，ThreadPoolExecutor它会调用poll或take方法，先poll，再take，只要其中一个接口有返回就行

在ScheduledThreadPoolExecutor内部有一个ScheduledFutureTask类实现了RunnableScheduledFuture，ScheduledFutureTask这个类采用了装饰者设计模式，在执行Runnable的方法基础上还执行了一些额外的功能。
我们需要特别注意几个参数period、time。
（1）time
首先看一下time的作用，可以发现time是用于获取执行延时时间的，也就是delay是根据time生成的

定时器+线程池

定时器+线程池

• 定时器
• 线程池
• • 创建
  • Executors

定时器

定时器：定时器就像设置一个闹钟，当时间到达后完成某件事情，像JS中的是setTimeout。
(JS中的setInterval是每隔多久执行一次)

1、我们使用定时器的时候，最主要的是小一个任务Runnable，TimeTask就实现了Runnable接口，所以我们直接创建一个Task。
2、设置定时器：Timer timer = new Timer();

3、调度：利用timer.schedule()方法设置task和delay；
schedule方法：

例如：会在5秒后打印：hello

public class Demo 
    public static void main(String[] args) 
        TimerTask task = new TimerTask() 
            @Override
            public void run() 
                System.out.println("hello");
            
        ;

        Timer timer = new Timer();
        timer.schedule(task,5000);
    

scheduleAtFixedRate是周期性执行任务
例如：timer.scheduleAtFixedRate(task,1000,2000);就是1秒后执行task，然后每隔2秒执行一次。

线程池

为什么需要线程池呢？
如果每次来任务都创建一个新的线程，那么会造成很大的损失。
如果可以将创建的线程放进线程池，下一次如果还需要这个线程，就可以直接使用。
线程池的最大好处就是减少每次启动销毁的损耗

创建

构造方法：


拒绝策略：

Executors

工厂类Executors，可以将new的步骤省略

Executors.newFixedThreadPool(3);
//就是new一个固定大小的线程池

Executors.newCachedThreadPool();
//创建临时的

例如：利用线程池计算斐波那契数：

package threadpool;

import java.util.Scanner;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class Demo 
    public static void main(String[] args) 
        ExecutorService pool = Executors.newFixedThreadPool(3);
        Scanner sc = new Scanner(System.in);
        System.out.println("请输入:");
        while (sc.hasNextInt()) 
            int n = sc.nextInt();
            Runnable runnable = new Runnable() 
                @Override
                public void run() 
                    long r = fib(n);
                    System.out.printf("fib(%d) = %d\\n", n, r);
                
            ;

            pool.execute(runnable);
            System.out.println("请输入:");
        
    


    private static int fib(int n) 
        if (n < 2) 
            return n;
        
        return fib(n - 1) + fib(n - 2);