/***************************************************
* TODO: description .
* @author: gao_chun
* @since: 2015-4-17
* @version: 1.0.0
* @remark: 转载请注明出处
**************************************************/
java.util.concurrent.Executor
使用 Executor 的软件包 | |
---|---|
java.util.concurrent | 在并发编程中很常用的工具类。 |
java.util.concurrent 中 Executor 的使用 |
---|
java.util.concurrent 中 Executor 的子接口 | |
---|---|
interface |
ExecutorService
|
interface |
ScheduledExecutorService
一个 |
实现 Executor 的 java.util.concurrent 中的类 | |
---|---|
class |
AbstractExecutorService
提供 |
class |
ScheduledThreadPoolExecutor
|
class |
ThreadPoolExecutor
一个 |
参数类型为 Executor 的 java.util.concurrent 中的构造方法 | |
---|---|
ExecutorCompletionService(Executor executor)
使用为执行基本任务而提供的执行程序创建一个 ExecutorCompletionService,并将 |
|
ExecutorCompletionService(Executor executor, BlockingQueue<Future<V>> completionQueue)
使用为执行基本任务而提供的执行程序创建一个 ExecutorCompletionService,并将所提供的队列作为其完成队列。 |
示例:
- package stu.executor;
- import java.util.concurrent.Executor;
- import java.util.concurrent.Executors;
- /**
- * 定时器测试
- *
- */
- public class TestExecutor {
- private Executor executor;
- /**
- * 设置执行器
- *
- * @param executor
- */
- public void setExecutor(Executor executor) {
- this.executor = executor;
- }
- /**
- * 用执行器执行多个任务
- */
- public void executeTasks() {
- //连续执行10个任务
- for (int i = 0; i < 10; i++) {
- executor.execute(new TestTask("任务" + i));
- }
- }
- public static void main(String[] args) {
- TestExecutor testExecutor = new TestExecutor();
- testExecutor.setExecutor(Executors.newFixedThreadPool(2));
- testExecutor.executeTasks();
- }
- }
[java] view
plaincopy
- package stu.executor;
- /**
- * 一个实现了Runnable接口的任务
- */
- public class TestTask implements Runnable {
- private String taskName;
- public TestTask(String taskName) {
- this.taskName = taskName;
- }
- public void run() {
- //一个比较耗时的工作
- for (int i = 0; i < 9999999; i++) ;
- System.out.println("执行 " + taskName + " ,所在线程ID为:" + Thread.currentThread().getId());
- }
- }
执行给定的在未来某个时间的命令。命令可以在一个新的线程上执行,在池的线程,或在调用线程。
理解:在以后的某个时刻去执行,异步执行。
- 命令运行的Task
- 如果此任务不能接受执行抛出RejectedExecutionException
- 如果命令是无效的抛出NullPointerException异常
深入理解
java执行器相关的类有:Executor
,Executors,ExecutorService。
Executor分析
Executor是一个接口,是用来执行 Runnable 任务的;它只定义一个方法- execute(Runnable command);执行 Ruannable 类型的任务。通过Executor
管理Thread 对象,可以简化编程。Executor在客户单和任务执行之间提供了一个中介层,通过中介来执行任务。Executor执行任务而无须管理任务的生命周期。因此,Executor是启动任务的首选方法。
Executors分析
注:Executors相当于对Executor的一个工具类
Executors 类有几个重要的方法:
callable(Runnable task): 将 Runnable 的任务转化成 Callable 的任务
newSingleThreadExecutor(): 产生一个 ExecutorService 对象,这个对象只有一个线程可用来执行任务,若任务多于一个,将按先后顺序执行。
newCachedThreadPool(): 产生一个 ExecutorService 对象,这个对象带有一个线程池,线程池的大小会根据需要调整,线程执行完任务后返回线程池,供执行下一次任务使用。
newFixedThreadPool(int poolSize): 产生一个 ExecutorService 对象,这个对象带有一个大小为 poolSize 的线程池,若任务数量大于 poolSize ,任务会被放在一个 queue 里顺序执行。
newSingleThreadScheduledExecutor(): 产生一个 ScheduledExecutorService 对象,这个对象的线程池大小为 1 ,若任务多于一个,任务将按先后顺序执行。
newScheduledThreadPool(int poolSize): 产生一个 ScheduledExecutorService 对象,这个对象的线程池大小为 poolSize ,若任务数量大于 poolSize ,任务会在一个 queue 里等待执行。
在Executors还包含了几个内部类:DefaultThreadFactory,DelegatedExecutorService,DelegatedScheduledExecutorService,PrivilegedCallable<T>,RunnableAdapter<T>,这几个类为call方法提供了支持。