码迷,mamicode.com
首页 > 编程语言 > 详细

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

时间:2015-04-17 13:51:39      阅读:164      评论:0      收藏:0      [点我收藏+]

标签:并发   executor   java   线程   管理   


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

 * 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 
          Executor 提供了管理终止的方法,以及可为跟踪一个或多个异步任务执行状况而生成 Future 的方法。
 interface ScheduledExecutorService 
          一个 ExecutorService,可安排在给定的延迟后运行或定期执行的命令。
 

实现 Executor 的 java.util.concurrent 中的类
 class AbstractExecutorService 
          提供 ExecutorService 执行方法的默认实现。
 class ScheduledThreadPoolExecutor 
          ThreadPoolExecutor,它可另行安排在给定的延迟后运行命令,或者定期执行命令。
 class ThreadPoolExecutor 
          一个 ExecutorService,它使用可能的几个池线程之一执行每个提交的任务,通常使用 Executors 工厂方法配置。
 

参数类型为 Executor 的 java.util.concurrent 中的构造方法
ExecutorCompletionService(Executor executor) 
          使用为执行基本任务而提供的执行程序创建一个 ExecutorCompletionService,并将 LinkedBlockingQueue 作为完成队列。
ExecutorCompletionService(Executor executor, BlockingQueue<Future<V>> completionQueue) 
          使用为执行基本任务而提供的执行程序创建一个 ExecutorCompletionService,并将所提供的队列作为其完成队列。

示例:

  1. package stu.executor;   
  2.   
  3. import java.util.concurrent.Executor;   
  4. import java.util.concurrent.Executors;   
  5.   
  6. /**  
  7. * 定时器测试  
  8.  
  9. */   
  10. public class TestExecutor {   
  11.         private Executor executor;   
  12.   
  13.         /**  
  14.          * 设置执行器  
  15.          *  
  16.          * @param executor  
  17.          */   
  18.         public void setExecutor(Executor executor) {   
  19.                 this.executor = executor;   
  20.         }   
  21.   
  22.         /**  
  23.          * 用执行器执行多个任务  
  24.          */   
  25.         public void executeTasks() {   
  26.                 //连续执行10个任务   
  27.                 for (int i = 0; i < 10; i++) {   
  28.                         executor.execute(new TestTask("任务" + i));   
  29.                 }   
  30.         }   
  31.   
  32.         public static void main(String[] args) {   
  33.                 TestExecutor testExecutor = new TestExecutor();   
  34.                 testExecutor.setExecutor(Executors.newFixedThreadPool(2));   
  35.                 testExecutor.executeTasks();   
  36.         }   
  37. }  
[java] view plaincopy
  1. package stu.executor;   
  2.   
  3. /**  
  4. * 一个实现了Runnable接口的任务  
  5. */   
  6. public class TestTask implements Runnable {   
  7.         private String taskName;   
  8.   
  9.         public TestTask(String taskName) {   
  10.                 this.taskName = taskName;   
  11.         }   
  12.   
  13.         public void run() {   
  14.                 //一个比较耗时的工作   
  15.                 for (int i = 0; i < 9999999; i++) ;   
  16.                 System.out.println("执行 " + taskName + " ,所在线程ID为:" + Thread.currentThread().getId());   
  17.         }   
  18. }  


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

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

  • 命令运行的Task
  • 如果此任务不能接受执行抛出RejectedExecutionException
  • 如果命令是无效的抛出NullPointerException异常

技术分享


深入理解

java执行器相关的类有:ExecutorExecutorsExecutorService

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还包含了几个内部类:DefaultThreadFactoryDelegatedExecutorServiceDelegatedScheduledExecutorServicePrivilegedCallable<T>RunnableAdapter<T>,这几个类为call方法提供了支持。


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

标签:并发   executor   java   线程   管理   

原文地址:http://blog.csdn.net/gao_chun/article/details/45094931

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!