深入java线程池的使用详解

更新时间：2013年05月16日 17:54:29 作者：

本篇文章是对java线程池的使用进行了详细的分析介绍，需要的朋友参考下

在Java 5.0之前启动一个任务是通过调用Thread类的start()方法来实现的，任务的提于交和执行是同时进行的，如果你想对任务的执行进行调度或是控制同时执行的线程数量就需要额外编写代码来完成。5.0里提供了一个新的任务执行架构使你可以轻松地调度和控制任务的执行，并且可以建立一个类似数据库连接池的线程池来执行任务。这个架构主要有三个接口和其相应的具体类组成。这三个接口是Executor, ExecutorService、ScheduledExecutorService，让我们先用一个图来显示它们的关系：

图的左侧是接口，图的右侧是这些接口的具体类。注意Executor是没有直接具体实现的。
Executor接口：是用来执行Runnable任务的，它只定义一个方法：
•execute(Runnable command)：执行Ruannable类型的任务
ExecutorService接口：ExecutorService继承了Executor的方法，并提供了执行Callable任务和中止任务执行的服务，其定义的方法主要有：
•submit(task)：可用来提交Callable或Runnable任务，并返回代表此任务的Future对象
•invokeAll(collection of tasks)：批处理任务集合，并返回一个代表这些任务的Future对象集合
•shutdown()：在完成已提交的任务后关闭服务，不再接受新任务
•shutdownNow()：停止所有正在执行的任务并关闭服务。
•isTerminated()：测试是否所有任务都执行完毕了。
•isShutdown()：测试是否该ExecutorService已被关闭
ScheduledExecutorService接口在ExecutorService的基础上，ScheduledExecutorService提供了按时间安排执行任务的功能，它提供的方法主要有：
•schedule(task, initDelay): 安排所提交的Callable或Runnable任务在initDelay指定的时间后执行。
•scheduleAtFixedRate()：安排所提交的Runnable任务按指定的间隔重复执行
•scheduleWithFixedDelay()：安排所提交的Runnable任务在每次执行完后，等待delay所指定的时间后重复执行。

重要的Executors类
虽然以上提到的接口有其实现的具体类，但为了方便Java 5.0建议使用Executors的工具类来得到Executor接口的具体对象，需要注意的是Executors是一个类，不是Executor的复数形式。Executors提供了以下一些static的方法：
•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来建立Thread pool

有时候您需要建立一堆Thread来执行一些小任务，然而频繁的建立Thread有时会是个开销，因为Thread的建立必须与作业系统互动，如果能建立一个Thread pool来管理这些小的Thread并加以重复使用，对于系统效能会是个改善的方式。
您可以使用Executors来建立Thread pool，Executors有几个static方法，列出如下：

方法	说明
`newCachedThreadPool`	建立可以快取的Thread，每个Thread预设可idle 60秒
`newFixedThreadPool`	包括固定数量的Thread
`newSingleThreadExecutor`	只有一个Thread，循序的执行指定给它的每个任务
`newScheduledThreadPool`	可排程的Thread
`newSingleThreadScheduledExecutor`	单一可排程的Thread

举个简单的实例，下面的程式使用newFixedThreadPool方法建立Thread pool，当中包括五个可以重复使用的Thread，您可以指定Runnable物件给它，程式中会产生十个Runnable物件，由于Thread pool中只有五个可用的Thread，所以后来建立的五个Runnable必须等待有空闲的Thread才会被执行：
•ExecutorDemo.java

复制代码代码如下:

package onlyfun.caterpillar;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class ExecutorDemo {
 public static void main(String[] args) {
  ExecutorService service = Executors.newFixedThreadPool(5);

  for(int i = 0; i < 10; i++) {
   final int count = i;
   service.submit
(new Runnable() {
    public void run() {
     System.out.println(count);
     try {
      Thread.sleep(2000);
     } catch (InterruptedException e) {
      e.printStackTrace();
     }

    }
   });
  }

  service.shutdown(); // 最后记得关闭Thread pool
 }
}

submit()方法也接受实作Callable介面的物件，最后传回Future物件，可以取得Callable执行过后的传回结果。如果想利用Executors进行排程，例如排定某个工作30秒后执行：

复制代码代码如下:

ScheduledExecutorService scheduler = Executors.newSingleThreadScheduledExecutor( );        
scheduler.schedule(new Runnable( ) {                               
public void run() {                                   
// 排程工作                               
}                           
},                           
30, TimeUnit.SECONDS);

或排定某个工作5秒后执行，之后每30秒执行一次：

复制代码代码如下:

 final ScheduledFuture future = scheduler.scheduleAtFixedRate(new Runnable( ) {                               
 public void run() {                                   
 // 排程工作                                   
 System.out.println("t");                               
 }                           
 },                           
 0, 5, TimeUnit.SECONDS);               
 // 排定 60 秒后取消future        
 scheduler.schedule(new Runnable( ) {            
 public void run( ) {              
 future.cancel(false);            
 }          
 }, 60, TimeUnit.SECONDS);

如上所示，想要取消排程任务，可以呼叫ScheduledFuture的cancel()方法。

您可能感兴趣的文章:

C语言中获取进程识别码的相关函数
这篇文章主要介绍了C语言中获取进程识别码的相关函数,分别为getpid()函数和getppid()函数的使用,需要的朋友可以参考下
2015-08-08
C语言约瑟夫环的实现
这篇文章主要介绍了C语言约瑟夫环的实现的相关资料,这里主要是利用数据数据结果中循环链表来实现，需要的朋友可以参考下
2017-08-08
C语言链表实现歌手评分系统
这篇文章主要为大家详细介绍了C语言链表实现歌手评分系统，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2019-03-03
EasyC++函数模板介绍
这篇文章主要介绍了C++函数模板介绍，所谓函数的模板，本质上也就是使用泛型来定义函数，所谓的泛型其实也就是不定的类型，比如说我们使用vector的时候，可以定义各种类型的vector，下面我们一起进入文章详细了解一下C++函数模板,需要的朋友可以参考一下
2021-12-12
C++ 内存分配处理函数set_new_handler的使用
这篇文章主要介绍了C++ 内存分配处理函数set_new_handler的使用，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2020-02-02
带你了解如何用C++合并两个有序链表
这篇文章主要介绍了c++ 如何合并两个有序链表,小编感觉这篇文章还不错，希望能帮助大家更好的理解和学习C++,感兴趣的朋友可以了解下
2021-08-08
Qt利用ImageWatch实现图片查看功能
Visual Studio有专门针对OpenCV开发的插件，名叫ImageWatch，图片放大之后可以查看RGB的像素值。本文将利用这一查件实现图片查看功能，需要的可以参考一下
2022-04-04
Java C++算法题解leetcode1592重新排列单词间的空格
这篇文章主要为大家介绍了Java C++算法题解leetcode1592重新排列单词间的空格示例，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
2022-09-09
opencv3/C++ PHash算法图像检索详解
今天小编就为大家分享一篇opencv3/C++ PHash算法图像检索详解，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
2019-12-12
C++中 ‘=default ’及‘ =delete ’的使用
这篇文章主要介绍了C++中 =default 及 =delete 使用，使用=default和=delete可以控制编译器默认函数体的使用，下面我们就来看看具体的室友方法吧,需要的朋友也可以参考一下
2021-12-12