定时器+线程池

Posted 2021-08-08 无赖H4

定时器+线程池

• 定时器
• 线程池
• • 创建
  • 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);
    }
}