快捷搜索:  汽车  科技

java并发容器和同步器(java并发编程中常用的工具类)

java并发容器和同步器(java并发编程中常用的工具类)Executor 提供了管理终止的方法,以及可为跟踪一个或多个异步任务执行状况而生成 Future 的方法。 interfaceScheduledExecutorService 使用 Executor 的软件包java.util.concurrent在并发编程中很常用的工具类。 java.util.concurrent 中 Executor 的使用 java.util.concurrent 中 Executor 的子接口 interfaceExecutorService * @version: 1.0.0 * @remark: 转载请注明出处 **************************************************/

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

* 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 的子接口 interfaceExecutorService

Executor 提供了管理终止的方法,以及可为跟踪一个或多个异步任务执行状况而生成 Future 的方法。 interfaceScheduledExecutorService

一个 ExecutorService,可安排在给定的延迟后运行或定期执行的命令。 实现 Executor 的 java.util.concurrent 中的类 classAbstractExecutorService

提供 ExecutorService 执行方法的默认实现。 classScheduledThreadPoolExecutor

ThreadPoolExecutor,它可另行安排在给定的延迟后运行命令,或者定期执行命令。 classThreadPoolExecutor

一个 ExecutorService,它使用可能的几个池线程之一执行每个提交的任务,通常使用 Executors 工厂方法配置。 参数类型为 Executor 的 java.util.concurrent 中的构造方法ExecutorCompletionService(Executor executor)

使用为执行基本任务而提供的执行程序创建一个 ExecutorCompletionService,并将 LinkedBlockingQueue 作为完成队列。ExecutorCompletionService(Executor executor BlockingQueue<Future<V>> completionQueue)

使用为执行基本任务而提供的执行程序创建一个 ExecutorCompletionService,并将所提供的队列作为其完成队列。

深入理解

java执行器相关的类有:Executor ,Executors,ExecutorService。

Executor分析

Executor是一个接口,是用来执行 Runnable 任务的;它只定义一个方法- execute(Runnable command);执行 Ruannable 类型的任务。通过Executor 管理Thread 对象,可以简化编程。Executor在客户单和任务执行之间提供了一个中介层,通过中介来执行任务。Executor执行任务而无须管理任务的生命周期。因此,Executor是启动任务的首选方法。

Executors分析

java并发容器和同步器(java并发编程中常用的工具类)(1)

注: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方法提供了支持。

猜您喜欢: