java并发编程中常用的工具类 Executor

/***************************************************

 * TODO: description .

 * @author: gao_chun

 * @since:  2015-4-17

 * @version: 1.0.0

 * @remark: 转载请注明出处

 **************************************************/

java.util.concurrent.Executor

示例：

1. package stu.executor;
2. import java.util.concurrent.Executor;
3. import java.util.concurrent.Executors;
4. /**
5. * 定时器测试
6. *
7. */
8. public class TestExecutor {
9. private Executor executor;
10. /**
11. * 设置执行器
12. *
13. * @param executor
14. */
15. public void setExecutor(Executor executor) {
16. this.executor = executor;
17. }
18. /**
19. * 用执行器执行多个任务
20. */
21. public void executeTasks() {
22. //连续执行10个任务
23. for (int i = 0; i < 10; i++) {
24. executor.execute(new TestTask("任务" + i));
25. }
26. }
27. public static void main(String[] args) {
28. TestExecutor testExecutor = new TestExecutor();
29. testExecutor.setExecutor(Executors.newFixedThreadPool(2));
30. testExecutor.executeTasks();
31. }
32. }

[java] view
plaincopy

1. package stu.executor;
2. /**
3. * 一个实现了Runnable接口的任务
4. */
5. public class TestTask implements Runnable {
6. private String taskName;
7. public TestTask(String taskName) {
8. this.taskName = taskName;
9. }
10. public void run() {
11. //一个比较耗时的工作
12. for (int i = 0; i < 9999999; i++) ;
13. System.out.println("执行 " + taskName + " ,所在线程ID为：" + Thread.currentThread().getId());
14. }
15. }

执行给定的在未来某个时间的命令。命令可以在一个新的线程上执行，在池的线程，或在调用线程。

理解：在以后的某个时刻去执行，异步执行。

• 命令运行的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方法提供了支持。