当前位置: 代码迷 >> 综合 >> JDK源码阅读 java.util.concurrent.Executors相关分析
  详细解决方案

JDK源码阅读 java.util.concurrent.Executors相关分析

热度:27   发布时间:2023-12-17 09:13:13.0


 在jdk的java.util.concurrent,提供了Executor相关的类来帮助我们创建线程并管理线程的执行顺序。

1.类之间的关系

与java执行器相关的类有:Executor ,Executors,ExecutorService 。其中Executor为接口,此接口提供一种将任务提交与每个任务将如何运行的机制(包括线程使用的细节、调度等)分离开来的方法。通常使用 Executor 而不是显式地创建线程。Exectors 类:java.util.concurrent.Executors工具类是创建线程池的工具类。注意到上面两个类的区别没有。就好像集合里面的: Collection是集合类的上级接口,继承与他的接口主要有Set 和List.Collections是针对集合类的一个帮助类,他提供一系列静态方法实现对各种集合的搜索、排序、线程安全化等操作。ExecutorService 接口: 继承Executor接口,提供了执行Callable任务和中止任务执行的服务。

2.Executor分析

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

3.Executors分析

Executors相当于对Executor的一个工具类。

Executors 类有几个重要的方法,在这里简明一下:
    1 、 callable(Runnable task):      将 Runnable 的任务转化成 Callable 的任务
    2 、 newSingleThreadExecutor():    产生一个 ExecutorService 对象,这个对象只有一个线程可用来执行任务,若任务多于一个,任务将按先后顺序执行。
    3 、 newCachedThreadPool():        产生一个 ExecutorService 对象,这个对象带有一个线程池,线程池的大小会根据需要调整,线程执行完任务后返回线程池,供执行下一次任务使用。
    4 、 newFixedThreadPool(int poolSize):  产生一个 ExecutorService 对象,这个对象带有一个大小为 poolSize 的线程池,若任务数量大于 poolSize ,任务会被放在一个 queue 里顺序执行。
    5 、 newSingleThreadScheduledExecutor(): 产生一个 ScheduledExecutorService 对象,这个对象的线程池大小为 1 ,若任务多于一个,任务将按先后顺序执行。
    6 、 newScheduledThreadPool(int poolSize): 产生一个 ScheduledExecutorService 对象,这个对象的线程池大小为 poolSize ,若任务数量大于 poolSize ,任务会在一个 queue 里等待执行 。

另外,在Executors还包含了几个内部类,分别是:DefaultThreadFactory,DelegatedExecutorService,DelegatedScheduledExecutorService,PrivilegedCallable<T>,RunnableAdapter<T>,这几个类为call方法提供了支持。

最后附上一个Executor的简单代码:


   

 

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(); } 
}

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()); } 
}