并发编程深入解析：自定义并发类实现周期性任务调度

目录

ScheduledThreadPoolExecutor

一、主程序

二、自定义周期线程池

三、自定义周期任务类

四、一个被执行的普通任务

五、执行结果

ScheduledThreadPoolExecutor

周期调度性线程池&＃xff08;Scheduled thread pool&＃xff09;是一个Executor框架的基本线程池的拓展。

• 延迟任务&＃xff08;Delayed task&＃xff09;&＃xff1a;在一段时间后执行一次。&＃xff08;可执行Callable和Runnable对象&＃xff09;
• 周期任务&＃xff08;Periodic task&＃xff09;&＃xff1a;在一段时间后&＃xff0c;永久地周期性地执行。&＃xff08;只能执行Runnable对象&＃xff09;

一、主程序

package xyz.jangle.thread.test.n8_6.schedule;import java.util.Date;
import java.util.concurrent.TimeUnit;/*** 8.6、自定义在周期调度线程池中运行的任务类* &＃64;author jangle* &＃64;email jangle&＃64;jangle.xyz* &＃64;time 2020年9月25日 上午9:20:05* */
public class M {public static void main(String[] args) throws Exception {// 使用自定义周期线程池MyScheduledThreadPoolExecutor executor &＃61; new MyScheduledThreadPoolExecutor(4);Task task &＃61; new Task();System.out.println("Main: " &＃43; new Date());executor.schedule(task, 1, TimeUnit.SECONDS);TimeUnit.SECONDS.sleep(6);task &＃61; new Task();System.out.println("Main:" &＃43; new Date());executor.scheduleAtFixedRate(task, 1, 3, TimeUnit.SECONDS);TimeUnit.SECONDS.sleep(10);executor.shutdown();executor.awaitTermination(1, TimeUnit.DAYS);System.out.println("Main:End of the program.");}}


二、自定义周期线程池

package xyz.jangle.thread.test.n8_6.schedule;import java.util.concurrent.RunnableScheduledFuture;
import java.util.concurrent.ScheduledFuture;
import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.TimeUnit;/*** 自定义&＃xff08;继承重写&＃xff09;周期调度线程池* &＃64;author jangle* &＃64;email jangle&＃64;jangle.xyz* &＃64;time 2020年9月25日 下午3:15:44* */
public class MyScheduledThreadPoolExecutor extends ScheduledThreadPoolExecutor {public MyScheduledThreadPoolExecutor(int corePoolSize) {super(corePoolSize);}&＃64;Overrideprotected RunnableScheduledFuture decorateTask(Runnable runnable, RunnableScheduledFuture task) {// 该方法会被 schedule、scheduleAtFixedRate、scheduleWithFixedDelay 方法内部调用// 这个方法的任务是对原任务进行包装。// 包装后的任务必须是实现RunnableScheduledFuture接口的类&＃xff08;因为线程池需要判断是否是周期任务&＃xff09;return new MyScheduledTask(runnable, null, task, this);}&＃64;Overridepublic ScheduledFuture scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit) {// scheduleAtFixedRate 方法会调用decorateTask方法&＃xff0c;所以会返回MyScheduledTask类型的对象ScheduledFuture task &＃61; super.scheduleAtFixedRate(command, initialDelay, period, unit);MyScheduledTask myTask &＃61; (MyScheduledTask) task;myTask.setPeriod(TimeUnit.MILLISECONDS.convert(period, unit));return myTask;}}


三、自定义周期任务类

在周期调度执行器中执行的任务必须实现RunnableScheduledFuture接口并拓展FutureTask类。

package xyz.jangle.thread.test.n8_6.schedule;import java.util.Date;
import java.util.concurrent.Delayed;
import java.util.concurrent.FutureTask;
import java.util.concurrent.RunnableScheduledFuture;
import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.TimeUnit;/*** 自定义在周期调度线程池中运行的任务类* &＃64;author jangle* &＃64;email jangle&＃64;jangle.xyz* &＃64;time 2020年9月25日 上午9:22:49* */
public class MyScheduledTask extends FutureTask implements RunnableScheduledFuture {// 原任务private RunnableScheduledFuture task;// 线程池private ScheduledThreadPoolExecutor executor;// 运行周期private long period;// 用于周期任务&＃xff08;开始执行的时间&＃xff09;private long startDate;public MyScheduledTask(Runnable runnable, V result, RunnableScheduledFuture task,ScheduledThreadPoolExecutor executor) {super(runnable, result);this.task &＃61; task;this.executor &＃61; executor;}&＃64;Overridepublic long getDelay(TimeUnit unit) {if (!isPeriodic()) {return task.getDelay(unit);} else {if (startDate &＃61;&＃61; 0) {return task.getDelay(unit);} else {var now &＃61; new Date();long delay &＃61; startDate - now.getTime();long res &＃61; unit.convert(delay, TimeUnit.MILLISECONDS);
// System.out.println("******delay:" &＃43; delay &＃43; ",res" &＃43; res);return res;}}}&＃64;Overridepublic int compareTo(Delayed o) {return task.compareTo(o);}&＃64;Overridepublic boolean isPeriodic() {return task.isPeriodic();}&＃64;Overridepublic void run() {if (isPeriodic() && (!executor.isShutdown())) {var now &＃61; new Date();startDate &＃61; now.getTime() &＃43; period;executor.getQueue().add(this);}System.out.println("MyScheduledTask-Pre:" &＃43; new Date());System.out.println("MyScheduledTask: 是否是周期性任务&＃xff1a;" &＃43; isPeriodic());super.runAndReset();System.out.println("MyScheduledTask-Post:" &＃43; new Date());System.out.println("*************************");}public void setPeriod(long period) {this.period &＃61; period;}}


四、一个被执行的普通任务

package xyz.jangle.thread.test.n8_6.schedule;import java.util.concurrent.TimeUnit;/*** 普通的任务* &＃64;author jangle* &＃64;email jangle&＃64;jangle.xyz* &＃64;time 2020年9月25日 下午4:02:28* */
public class Task implements Runnable {&＃64;Overridepublic void run() {System.out.println("Task: Begin.");try {TimeUnit.SECONDS.sleep(2);} catch (InterruptedException e) {e.printStackTrace();}System.out.println("Task: End.");}}


五、执行结果

Main: Sat Oct 03 09:23:16 CST 2020
MyScheduledTask-Pre:Sat Oct 03 09:23:17 CST 2020
MyScheduledTask: 是否是周期性任务&＃xff1a;false
Task: Begin.
Task: End.
MyScheduledTask-Post:Sat Oct 03 09:23:19 CST 2020
*************************
Main:Sat Oct 03 09:23:22 CST 2020
MyScheduledTask-Pre:Sat Oct 03 09:23:23 CST 2020
MyScheduledTask: 是否是周期性任务&＃xff1a;true
Task: Begin.
Task: End.
MyScheduledTask-Post:Sat Oct 03 09:23:25 CST 2020
*************************
MyScheduledTask-Pre:Sat Oct 03 09:23:26 CST 2020
MyScheduledTask: 是否是周期性任务&＃xff1a;true
Task: Begin.
Task: End.
MyScheduledTask-Post:Sat Oct 03 09:23:28 CST 2020
*************************
MyScheduledTask-Pre:Sat Oct 03 09:23:29 CST 2020
MyScheduledTask: 是否是周期性任务&＃xff1a;true
Task: Begin.
Task: End.
MyScheduledTask-Post:Sat Oct 03 09:23:31 CST 2020
*************************
Main:End of the program.