Executor主要由3大部分组成。
下面是这些类和接口的简介。
Executor框架的主要成员:ThreadPoolExecutor、ScheduledThreadPoolExecutor、Future接口、Runnable接口、Callable接口、Executors。
ThreadPoolExecutor通常使用工厂类Executors来创建,Executors可以创建3种类型的ThreadPoolExecutor:SingleThreadExecutor、FixThreadPool、CachedThreadPool。
SchduledThreadPoolExecutor通常使用工厂类Executors来创建,Executors可以创建2中类型的SchduledThreadPoolExecutor,如下:
Future接口和实现Future接口的FutureTask类用来表示异步计算的结果,当我们把Runnable接口或者Callable接口的实现类提交(submit)给ThreadPoolExecutor或者SchduledThreadPoolExecutor时,ThreadPoolExecutor或者SchduledThreadPoolExecutor会向我们返回一个FutureTask对象。下面是对应的API
Runnable和Callable接口的实现类都可以被hreadPoolExecutor或者SchduledThreadPoolExecutor执行。它们之间的区别是Runnable不会返回结果,而Callable可以返回结果。
除了可以自已创建实现Callable接口的对象外,还可以使用工厂类Executors来把一个Runnable包装成一个Callable。
当我们把一个Callable对象提交给ThreadPoolExecutor或者SchduledThreadPoolExecutor执行时,summit()会向我们返回一个FutureTask对象。我们可以执行FutureTask.get()来等待任务执行完成。当任务完成后FutureTask.get()将会返回任务的结果。
附录:简单的结构脑图
ScheduledThreadPoolExecutor主要用来执行需要延迟或者定时执行的任务,功能与Timer类似,不同的是Timer只能单线程允许,ScheduledThreadPoolExecutor可以指定多个线程。
ScheduledThreadPoolExecutor会把要执行的任务放在一个DelayQueue中,ScheduledThreadPoolExecutor会把Runable对象封装成ScheduledFutureTask,ScheduledFutureTask内部包含三个对象
ScheduledThreadPoolExecutor执行任务的流程大体是:
简单代码示例:
package main.java.com.robot.demo;
import java.util.Date;
import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
/**
* @author: 会跳舞的机器人
* @date: 2017/8/24 10:14
* @description: ScheduledThreadPoolExecutor
*/
public class ScheduledThreadPoolExecutorDemo {
private static ScheduledThreadPoolExecutor scheduledThreadPoolExecutor = new ScheduledThreadPoolExecutor(4);
public static void main(String[] args) {
// 初始化3秒后开始执行任务,此后每隔1秒执行一次
scheduledThreadPoolExecutor.scheduleAtFixedRate(new Runnable() {
@Override
public void run() {
System.out.println("正在执行任务,当前时间:" + new Date());
}
}, 3L, 1L, TimeUnit.SECONDS);
}
}
Future接口和FutureTask实现代表线程异步执行的结果,可以通过FutureTask.get()方法获取异步返回的结果。
示例:
package main.java.com.robot.demo;
import java.util.Date;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.FutureTask;
/**
* @author: 会跳舞的机器人
* @date: 2017/8/24 11:14
* @description: FutureTask示例
*/
public class FutureTaskDemo {
private static ExecutorService executorService = Executors.newSingleThreadExecutor();
public static void main(String[] args) {
FutureTask<String> futureTask = new FutureTask<>(new Callable<String>() {
@Override
public String call() throws Exception {
System.out.println("当前时间:" + new Date() + "执行任务......");
Thread.sleep(3000);
return "success";
}
});
// 提交任务
executorService.submit(futureTask);
// 获取返回结果
String result = "";
try {
result = futureTask.get();
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}
System.out.println("当前时间:" + new Date() + ",线程执行结果返回:" + result);
// 关闭线程池
executorService.shutdown();
}
}