ScheduledTheadPool线程池的使用

Posted 2020-10-25 一响贪欢

ScheduledTheadPool线程池的特点在于可以延迟执行任务，也可以周期性执行任务。

创建线程池

ScheduledExecutorService scheduled = Executors.newScheduledThreadPool(5);//参数为核心线程数，最大线程数无限大

定义一个简单的任务

class Work implements Runnable {
    @Override
    public void run() {
        System.out.println(Thread.currentThread().getName() + " start time : "+new Date());
        try {
            Thread.sleep(5000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println(Thread.currentThread().getName() + "end time : " + new Date());
    }
}

执行任务的几种方法：

1、立即执行某任务

System.out.println("current time : "+new Date());
for (int i = 0; i < 2; i++) {
    scheduled.execute(new Work());//待执行任务
}

输出结果：

current time : Mon Feb 26 11:31:14 CST 2018
pool-1-thread-2 start time : Mon Feb 26 11:31:14 CST 2018
pool-1-thread-1 start time : Mon Feb 26 11:31:14 CST 2018
pool-1-thread-1end time : Mon Feb 26 11:31:19 CST 2018
pool-1-thread-2end time : Mon Feb 26 11:31:19 CST 2018

结果分析：

程序先打印当前时间：‘11:31:14‘，然后进行for循环，添加两个任务进入线程池，添加方式为立即执行，因此任务各自首先打印开始时间为‘11:31:14‘，与最开始的当前时间相同。然后各自休眠5秒，再次打印时间‘11:31:19‘。

2、延迟执行

System.out.println("current time : "+new Date());
for (int i = 0; i < 2; i++) {
    scheduled.schedule(new Work(), 3, TimeUnit.SECONDS);//待执行任务，延迟时间，延迟时间单位
}

输出结果

current time : Mon Feb 26 11:34:56 CST 2018
pool-1-thread-1 start time : Mon Feb 26 11:34:59 CST 2018
pool-1-thread-2 start time : Mon Feb 26 11:34:59 CST 2018
pool-1-thread-1end time : Mon Feb 26 11:35:04 CST 2018
pool-1-thread-2end time : Mon Feb 26 11:35:04 CST 2018

结果分析：

程序打印当前时间：‘11:34:56‘，然后进行for循环，添加两个任务进线程池，添加方式为延迟执行，延迟时间为3秒。因此两个任务的开始时间均为‘11:34:59‘，然后执行任务需要5秒，最后打印任务完成时间‘11:35:04‘。

3、延迟且周期性执行(周期时间从线程开始执行计算)

System.out.println("current time : "+new Date());
for (int i = 0; i < 2; i++) {
    scheduled.scheduleAtFixedRate(new Work(), 3, 10, TimeUnit.SECONDS);//待执行时间，延迟时间，执行周期，时间单位
}

输出结果

current time : Mon Feb 26 11:48:51 CST 2018
pool-1-thread-1 start time : Mon Feb 26 11:48:54 CST 2018
pool-1-thread-2 start time : Mon Feb 26 11:48:54 CST 2018
pool-1-thread-1end time : Mon Feb 26 11:48:59 CST 2018
pool-1-thread-2end time : Mon Feb 26 11:48:59 CST 2018
pool-1-thread-1 start time : Mon Feb 26 11:49:04 CST 2018
pool-1-thread-2 start time : Mon Feb 26 11:49:04 CST 2018
pool-1-thread-2end time : Mon Feb 26 11:49:09 CST 2018
pool-1-thread-1end time : Mon Feb 26 11:49:09 CST 2018
pool-1-thread-4 start time : Mon Feb 26 11:49:14 CST 2018
pool-1-thread-3 start time : Mon Feb 26 11:49:14 CST 2018
pool-1-thread-4end time : Mon Feb 26 11:49:19 CST 2018
pool-1-thread-3end time : Mon Feb 26 11:49:19 CST 2018

结果分析：

程序打印当前时间：‘11:48:51‘，然后进行for循环，添加两个任务进线程池，添加方式为延迟且周期性执行，延迟时间为3秒，周期时间为10秒。因此两个任务的第一次开始时间均为‘11:48:54‘，然后执行任务需要5秒，打印第一次任务完成时间‘11:48:59‘。同时周期时间为任务的开始时间，即从‘11:48:54‘开始计算，到‘11:49:04‘开始第二次周期执行，因此第二次打印任务开始时间即为‘11:49:04‘。以此类推。

如果周期时间小于线程的执行时间，即线程已到第二个执行周期，但第一次任务仍未执行完成，则会进行等待，直到第一次任务完成，然后立即执行第二次任务。

4、延迟且周期性执行(周期时间从线程执行完成计算)

System.out.println("current time : "+new Date());
for (int i = 0; i < 2; i++) {
    scheduled.scheduleWithFixedDelay(new Work(), 3, 10, TimeUnit.SECONDS);//待执行时间，延迟时间，执行周期，时间单位

}

输出结果

current time : Mon Feb 26 12:00:55 CST 2018
pool-1-thread-1 start time : Mon Feb 26 12:00:58 CST 2018
pool-1-thread-2 start time : Mon Feb 26 12:00:58 CST 2018
pool-1-thread-2end time : Mon Feb 26 12:01:03 CST 2018
pool-1-thread-1end time : Mon Feb 26 12:01:03 CST 2018
pool-1-thread-1 start time : Mon Feb 26 12:01:13 CST 2018
pool-1-thread-2 start time : Mon Feb 26 12:01:13 CST 2018
pool-1-thread-2end time : Mon Feb 26 12:01:18 CST 2018
pool-1-thread-1end time : Mon Feb 26 12:01:18 CST 2018

结果分析：

程序打印当前时间：‘12:00:55‘，然后进行for循环，添加两个任务进线程池，添加方式为延迟且周期性执行，延迟时间为3秒，周期时间为10秒。因此两个任务的第一次开始时间均为‘12:00:58‘，然后执行任务需要5秒，打印第一次任务完成时间‘12:01:03‘。同时周期时间的开始为任务执行完成时间，即从‘12:01:03‘开始计算，到‘12:01:13‘开始第二次周期执行，因此第二次打印任务开始时间即为‘12:01:13‘。以此类推。