100字范文,内容丰富有趣,生活中的好帮手!
100字范文 > java并发编程中常用的工具类 Executor

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

时间:2021-10-08 00:29:56

相关推荐

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

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

*TODO: description .

* @author: gao_chun

* @since: -4-17

* @version: 1.0.0

*@remark: 转载请注明出处

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

java.util.concurrent.Executor

示例:

packagestu.executor; importjava.util.concurrent.Executor; importjava.util.concurrent.Executors; /** *定时器测试 * */ publicclassTestExecutor{ privateExecutorexecutor; /** *设置执行器 * *@paramexecutor */ publicvoidsetExecutor(Executorexecutor){ this.executor=executor; } /** *用执行器执行多个任务 */ publicvoidexecuteTasks(){ //连续执行10个任务 for(inti=0;i<10;i++){ executor.execute(newTestTask("任务"+i)); } } publicstaticvoidmain(String[]args){ TestExecutortestExecutor=newTestExecutor(); testExecutor.setExecutor(Executors.newFixedThreadPool(2)); testExecutor.executeTasks(); } }[java]view plain copypackagestu.executor; /** *一个实现了Runnable接口的任务 */ publicclassTestTaskimplementsRunnable{ privateStringtaskName; publicTestTask(StringtaskName){ this.taskName=taskName; } publicvoidrun(){ //一个比较耗时的工作 for(inti=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方法提供了支持。

本内容不代表本网观点和政治立场,如有侵犯你的权益请联系我们处理。
网友评论
网友评论仅供其表达个人看法,并不表明网站立场。