执行器框架提供了ThreadPoolExecutor类来执行Runnable和Callable任务。当任务被发送给执行器的时候,执行器会根据俄配合尽可能快地执行任务。但是如果我们不想让任务马上执行,而是想让任务过一段时间后再执行,或者周期性地执行,该怎么办呢。为了达到这个目的,执行器框架为我们提供了ScheduledThreadPoolExecutor类。
下面我们看一下如何使用这个类来实现延迟执行任务。
首先我们创建一个任务类,实现Callable接口,泛型类型为String。这个任务在控制台打印执行时间,并返回Hello World。
import java.util.Date;import java.util.concurrent.Callable;/** * 新建Task类并实现Callable接口 * * 打印当前任务名+执行时间 * * Created by hadoop on 2016/11/3. */public class Task implements Callable { private String name; public Task(String name) { this.name = name; } @Override public String call() throws Exception { System.out.printf("%s: Starting at : %s\n", name, new Date()); return "Hello World!"; }}
接下来我们实现主类main方法。首先通过执行器工厂Executors类的newScheduledThreadPool()方法来创建一个定时执行器,这个方法接收一个参数作为线程池最大线程数。接下来创建5个线程,并调用schedule方法来执行线程,每个线程都给定一个延迟执行时间,每个线程的延迟时间都间隔一秒。
import java.util.concurrent.Executors;import java.util.concurrent.ScheduledThreadPoolExecutor;import java.util.concurrent.TimeUnit;/** * 在执行器中延迟执行任务 * * 我们把任务发送给执行器框架,任务会马上执行,如果你想让任务在过一段时间后才执行,那么你需要使用ScheduledThreadPoolExecutor。 * * 创建五个任务,使用ScheduledThreadPoolExecutor的schedule(Callablecallable,long delay,TimeUnit unit)方法来执行。 * 这个方法接受三个参数(实现Callable接口的任务,延迟执行时间,时间单位) * * 如果需要执行任务执行的时间点,那么你需要计算当前时间与任务执行时间之间的时间间隔。 * * Created by hadoop on 2016/11/3. */public class Main { public static void main(String[] args) throws InterruptedException { ScheduledThreadPoolExecutor executor = (ScheduledThreadPoolExecutor)Executors.newScheduledThreadPool(1); for (int i = 1; i <= 5; i++) { Task task = new Task(String.valueOf(i)); executor.schedule(task, i, TimeUnit.SECONDS); } executor.shutdown(); executor.awaitTermination(1, TimeUnit.DAYS); }}
执行结果,可以看到每个任务都比上一个任务延迟一秒执行。
1: Starting at : Sat Feb 25 21:38:49 CST 20172: Starting at : Sat Feb 25 21:38:50 CST 20173: Starting at : Sat Feb 25 21:38:51 CST 20174: Starting at : Sat Feb 25 21:38:52 CST 20175: Starting at : Sat Feb 25 21:38:53 CST 2017