Java 多线程线程池之concurrent包，ExecutorService接口，ScheduledExecutorService接口和Executors类

小鱼儿 2022-08-13 18:51 77阅读 0赞

### 简介        ###

系统启动一个新线程的成本是比较高的，因为它涉及到与操作系统的交互。在这种情况下，使用线程池可以很好的提供性能，尤其是当程序中需要创建大量生存期很短暂的线程时，更应该考虑使用线程池。

与数据库连接池类似的是，线程池在系统启动时即创建大量空闲的线程，程序将一个Runnable对象传给线程池，线程池就会启动一条线程来执行该对象的run方法，当run方法执行结束后，该线程并不会死亡，而是再次返回线程池中成为空闲状态，等待执行下一个Runnable对象的run方法。

除此之外，使用线程池可以有效地控制系统中并发线程的数量，但系统中包含大量并发线程时，会导致系统性能剧烈下降，甚至导致JVM崩溃。而线程池的最大线程数参数可以控制系统中并发的线程不超过此数目。

在JDK1.5之前，开发者必须手动的实现自己的线程池，从JDK1.5之后，Java内建支持线程池。

与多线程并发的所有支持的类都在java.lang.concurrent包中。我们可以使用里面的类更好的控制多线程的执行。

### Executors类 ###

JDK1.5中提供Executors工厂类来产生连接池，该工厂类中包含如下的几个静态工程方法来创建连接池：

1、public static ExecutorService newFixedThreadPool(int nThreads)：创建一个可重用的、具有固定线程数的线程池。

2、public static ExecutorService newSingleThreadExecutor()：创建一个只有单线程的线程池，它相当于newFixedThreadPool方法是传入的参数为1

3、public static ExecutorService newCachedThreadPool()：创建一个具有缓存功能的线程池，系统根据需要创建线程，这些线程将会被缓存在线程池中。

4、public static ScheduledExecutorService newSingleThreadScheduledExecutor()：创建只有一条线程的线程池，他可以在指定延迟后执行线程任务

5、public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize)：创建具有指定线程数的线程池，它可以再指定延迟后执行线程任务，corePoolSize指池中所保存的线程数，即使线程是空闲的也被保存在线程池内。

上面的几个方法都有一个重载的方法，多传入一个ThreadFactory参数的重载方法，使用的比较少。

### ExecutorService ###

可以看到上面的5个方法中，前面3个方法的返回值都是一个ExecutorService对象。该ExecutorService对象就代表着一个尽快执行线程的线程池（只要线程池中有空闲线程立即执行线程任务），程序只要将一个Runnable对象或Callable对象提交给该线程池即可，该线程就会尽快的执行该任务。

ExecutorService有几个重要的方法：

<table style="color:rgb(0,0,0); font-family:Arial; font-size:14px; line-height:26px"> 
 <tbody> 
  <tr> 
   <th colspan="2" align="left"><span>方法摘要</span></th> 
  </tr> 
  <tr> 
   <td align="right"><span><code>&nbsp;boolean</code></span></td> 
   <td><code><strong><a href="http://write.blog.csdn.net/java/util/concurrent/ExecutorService.html#isShutdown%28%29" style="color:rgb(202,0,0); text-decoration:none" rel="nofollow">isShutdown</a></strong>()</code>&nbsp;<br> &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;如果此执行程序已关闭，则返回&nbsp;true。</td> 
  </tr> 
  <tr> 
   <td align="right"><span><code>&nbsp;boolean</code></span></td> 
   <td><code><strong><a href="http://write.blog.csdn.net/java/util/concurrent/ExecutorService.html#isTerminated%28%29" style="color:rgb(202,0,0); text-decoration:none" rel="nofollow">isTerminated</a></strong>()</code>&nbsp;<br> &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;如果关闭后所有任务都已完成，则返回&nbsp;true。</td> 
  </tr> 
  <tr> 
   <td align="right"><span><code>&nbsp;void</code></span></td> 
   <td><code><strong><a href="http://write.blog.csdn.net/java/util/concurrent/ExecutorService.html#shutdown%28%29" style="color:rgb(202,0,0); text-decoration:none" rel="nofollow">shutdown</a></strong>()</code>&nbsp;<br> &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;启动一次顺序关闭，执行以前提交的任务，但不接受新任务。</td> 
  </tr> 
  <tr> 
   <td align="right"><span><code>&nbsp;<a title="java.util 中的接口" href="http://write.blog.csdn.net/java/util/List.html" style="color:rgb(202,0,0); text-decoration:none" rel="nofollow">List</a>&lt;<a title="java.lang 中的接口" href="http://write.blog.csdn.net/java/lang/Runnable.html" style="color:rgb(202,0,0); text-decoration:none" rel="nofollow">Runnable</a>&gt;</code></span></td> 
   <td><code><strong><a href="http://write.blog.csdn.net/java/util/concurrent/ExecutorService.html#shutdownNow%28%29" style="color:rgb(202,0,0); text-decoration:none" rel="nofollow">shutdownNow</a></strong>()</code>&nbsp;<br> &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;试图停止所有正在执行的活动任务，暂停处理正在等待的任务，并返回等待执行的任务列表。</td> 
  </tr> 
  <tr> 
   <td align="right"><span><code></code></span> 
    <table> 
     <tbody> 
      <tr> 
       <td><span><code>&lt;T&gt;&nbsp;<a title="java.util.concurrent 中的接口" href="http://write.blog.csdn.net/java/util/concurrent/Future.html" style="color:rgb(202,0,0); text-decoration:none" rel="nofollow">Future</a>&lt;T&gt;</code></span></td> 
      </tr> 
     </tbody> 
    </table> </td> 
   <td><code><strong><a href="http://write.blog.csdn.net/java/util/concurrent/ExecutorService.html#submit%28java.util.concurrent.Callable%29" style="color:rgb(202,0,0); text-decoration:none" rel="nofollow">submit</a></strong>(<a title="java.util.concurrent 中的接口" href="http://write.blog.csdn.net/java/util/concurrent/Callable.html" style="color:rgb(202,0,0); text-decoration:none" rel="nofollow">Callable</a>&lt;T&gt;&nbsp;task)</code>&nbsp;<br> &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;提交一个返回值的任务用于执行，返回一个表示任务的未决结果的 Future。</td> 
  </tr> 
  <tr> 
   <td align="right"><span><code>&nbsp;<a title="java.util.concurrent 中的接口" href="http://write.blog.csdn.net/java/util/concurrent/Future.html" style="color:rgb(202,0,0); text-decoration:none" rel="nofollow">Future</a>&lt;?&gt;</code></span></td> 
   <td><code><strong><a href="http://write.blog.csdn.net/java/util/concurrent/ExecutorService.html#submit%28java.lang.Runnable%29" style="color:rgb(202,0,0); text-decoration:none" rel="nofollow">submit</a></strong>(<a title="java.lang 中的接口" href="http://write.blog.csdn.net/java/lang/Runnable.html" style="color:rgb(202,0,0); text-decoration:none" rel="nofollow">Runnable</a>&nbsp;task)</code>&nbsp;<br> &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;提交一个 Runnable 任务用于执行，并返回一个表示该任务的 Future。</td> 
  </tr> 
  <tr> 
   <td align="right"><span><code></code></span> 
    <table> 
     <tbody> 
      <tr> 
       <td><span><code>&lt;T&gt;&nbsp;<a title="java.util.concurrent 中的接口" href="http://write.blog.csdn.net/java/util/concurrent/Future.html" style="color:rgb(202,0,0); text-decoration:none" rel="nofollow">Future</a>&lt;T&gt;</code></span></td> 
      </tr> 
     </tbody> 
    </table> </td> 
   <td><code><strong><a href="http://write.blog.csdn.net/java/util/concurrent/ExecutorService.html#submit%28java.lang.Runnable,%20T%29" style="color:rgb(202,0,0); text-decoration:none" rel="nofollow">submit</a></strong>(<a title="java.lang 中的接口" href="http://write.blog.csdn.net/java/lang/Runnable.html" style="color:rgb(202,0,0); text-decoration:none" rel="nofollow">Runnable</a>&nbsp;task, T&nbsp;result)</code>&nbsp;<br> &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;提交一个 Runnable 任务用于执行，并返回一个表示该任务的 Future。</td> 
  </tr> 
 </tbody> 
</table>

更详细的参考JDK API文档。

submit方法是对 Executor接口execute方法的更好的封装，建议使用submit方法。

### ScheduleExecutorService ###

在上面的5个方法中，后面2个方法的返回值都是一个ScheduleExecutorService对象。ScheduleExecutorService代表可在指定延迟或周期性执行线程任务的线程池。

ScheduleExecutorService类是ExecutorService类的子类。所以，它里面也有直接提交任务的submit方法，并且新增了一些延迟任务处理的方法：

<table style="color:rgb(0,0,0); font-family:Arial; font-size:14px; line-height:26px"> 
 <tbody> 
  <tr> 
   <th colspan="2" align="left"><span>方法摘要</span></th> 
  </tr> 
  <tr> 
   <td align="right"><span><code></code></span> 
    <table> 
     <tbody> 
      <tr> 
       <td><span><code>&lt;V&gt;&nbsp;<a title="java.util.concurrent 中的接口" href="http://write.blog.csdn.net/java/util/concurrent/ScheduledFuture.html" style="color:rgb(202,0,0); text-decoration:none" rel="nofollow">ScheduledFuture</a>&lt;V&gt;</code></span></td> 
      </tr> 
     </tbody> 
    </table> </td> 
   <td><code><strong><a href="http://write.blog.csdn.net/java/util/concurrent/ScheduledExecutorService.html#schedule%28java.util.concurrent.Callable,%20long,%20java.util.concurrent.TimeUnit%29" style="color:rgb(202,0,0); text-decoration:none" rel="nofollow">schedule</a></strong>(<a title="java.util.concurrent 中的接口" href="http://write.blog.csdn.net/java/util/concurrent/Callable.html" style="color:rgb(202,0,0); text-decoration:none" rel="nofollow">Callable</a>&lt;V&gt;&nbsp;callable, long&nbsp;delay,&nbsp;<a title="java.util.concurrent 中的枚举" href="http://write.blog.csdn.net/java/util/concurrent/TimeUnit.html" style="color:rgb(202,0,0); text-decoration:none" rel="nofollow">TimeUnit</a>&nbsp;unit)</code>&nbsp;<br> &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;创建并执行在给定延迟后启用的 ScheduledFuture。</td> 
  </tr> 
  <tr> 
   <td align="right"><span><code>&nbsp;<a title="java.util.concurrent 中的接口" href="http://write.blog.csdn.net/java/util/concurrent/ScheduledFuture.html" style="color:rgb(202,0,0); text-decoration:none" rel="nofollow">ScheduledFuture</a>&lt;?&gt;</code></span></td> 
   <td><code><strong><a href="http://write.blog.csdn.net/java/util/concurrent/ScheduledExecutorService.html#schedule%28java.lang.Runnable,%20long,%20java.util.concurrent.TimeUnit%29" style="color:rgb(202,0,0); text-decoration:none" rel="nofollow">schedule</a></strong>(<a title="java.lang 中的接口" href="http://write.blog.csdn.net/java/lang/Runnable.html" style="color:rgb(202,0,0); text-decoration:none" rel="nofollow">Runnable</a>&nbsp;command, long&nbsp;delay,&nbsp;<a title="java.util.concurrent 中的枚举" href="http://write.blog.csdn.net/java/util/concurrent/TimeUnit.html" style="color:rgb(202,0,0); text-decoration:none" rel="nofollow">TimeUnit</a>&nbsp;unit)</code>&nbsp;<br> &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;创建并执行在给定延迟后启用的一次性操作。</td> 
  </tr> 
  <tr> 
   <td align="right"><span><code>&nbsp;<a title="java.util.concurrent 中的接口" href="http://write.blog.csdn.net/java/util/concurrent/ScheduledFuture.html" style="color:rgb(202,0,0); text-decoration:none" rel="nofollow">ScheduledFuture</a>&lt;?&gt;</code></span></td> 
   <td><code><strong><a href="http://write.blog.csdn.net/java/util/concurrent/ScheduledExecutorService.html#scheduleAtFixedRate%28java.lang.Runnable,%20long,%20long,%20java.util.concurrent.TimeUnit%29" style="color:rgb(202,0,0); text-decoration:none" rel="nofollow">scheduleAtFixedRate</a></strong>(<a title="java.lang 中的接口" href="http://write.blog.csdn.net/java/lang/Runnable.html" style="color:rgb(202,0,0); text-decoration:none" rel="nofollow">Runnable</a>&nbsp;command, long&nbsp;initialDelay, long&nbsp;period,&nbsp;<a title="java.util.concurrent 中的枚举" href="http://write.blog.csdn.net/java/util/concurrent/TimeUnit.html" style="color:rgb(202,0,0); text-decoration:none" rel="nofollow">TimeUnit</a>&nbsp;unit)</code>&nbsp;<br> &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;创建并执行一个在给定初始延迟后首次启用的定期操作，后续操作具有给定的周期；也就是将在&nbsp;initialDelay&nbsp;后开始执行，然后在&nbsp;initialDelay+period&nbsp;后执行，接着在&nbsp;initialDelay + 2 * period&nbsp;后执行，依此类推。</td> 
  </tr> 
  <tr> 
   <td align="right"><span><code>&nbsp;<a title="java.util.concurrent 中的接口" href="http://write.blog.csdn.net/java/util/concurrent/ScheduledFuture.html" style="color:rgb(202,0,0); text-decoration:none" rel="nofollow">ScheduledFuture</a>&lt;?&gt;</code></span></td> 
   <td><code><strong><a href="http://write.blog.csdn.net/java/util/concurrent/ScheduledExecutorService.html#scheduleWithFixedDelay%28java.lang.Runnable,%20long,%20long,%20java.util.concurrent.TimeUnit%29" style="color:rgb(202,0,0); text-decoration:none" rel="nofollow">scheduleWithFixedDelay</a></strong>(<a title="java.lang 中的接口" href="http://write.blog.csdn.net/java/lang/Runnable.html" style="color:rgb(202,0,0); text-decoration:none" rel="nofollow">Runnable</a>&nbsp;command, long&nbsp;initialDelay, long&nbsp;delay,&nbsp;<a title="java.util.concurrent 中的枚举" href="http://write.blog.csdn.net/java/util/concurrent/TimeUnit.html" style="color:rgb(202,0,0); text-decoration:none" rel="nofollow">TimeUnit</a>&nbsp;unit)</code>&nbsp;<br> &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;创建并执行一个在给定初始延迟后首次启用的定期操作，随后，在每一次执行终止和下一次执行开始之间都存在给定的延迟。</td> 
  </tr> 
 </tbody> 
</table>

### 线程池的简单使用的例子 ###

#### 固定大小的线程池 ####

package com.tao.test;
    
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    
    public class PoolTest {
    	public static void main(String[] args) {
    		ExecutorService pool=Executors.newFixedThreadPool(5);//创建一个固定大小为5的线程池
    		for(int i=0;i<7;i++){
    			pool.submit(new MyThread());
    		}
    		pool.shutdown();
    	}
    }
    class MyThread extends Thread{
        @Override
        public void run() {
                System.out.println(Thread.currentThread().getName()+"正在执行。。。");
        }
    }

输出结果：

pool-1-thread-1正在执行。。。
    pool-1-thread-3正在执行。。。
    pool-1-thread-2正在执行。。。
    pool-1-thread-4正在执行。。。
    pool-1-thread-4正在执行。。。
    pool-1-thread-5正在执行。。。
    pool-1-thread-1正在执行。。。

可以看到虽然我们呢创建了7个MyThread线程对象，但是由于受线程池的大小限制，只是开启了5个线程，这样就减少了并发线程的数量。

#### 单任务线程池 ####

public class PoolTest {
    	public static void main(String[] args) {
    		ExecutorService pool=Executors.newSingleThreadExecutor();//创建一个单线程池
    		for(int i=0;i<7;i++){
    			pool.submit(new MyThread());
    		}
    		pool.shutdown();
    	}
    }

输出结果：

pool-1-thread-1正在执行。。。
    pool-1-thread-1正在执行。。。
    pool-1-thread-1正在执行。。。
    pool-1-thread-1正在执行。。。
    pool-1-thread-1正在执行。。。
    pool-1-thread-1正在执行。。。
    pool-1-thread-1正在执行。。。

可以看到，线程池只开启了一个线程。

#### 创建可变尺寸的线程池 ####

public class PoolTest {
    	public static void main(String[] args) {
    		ExecutorService pool=Executors.newCachedThreadPool();
    		for(int i=0;i<5;i++){
    			pool.submit(new MyThread());
    		}
    		pool.shutdown();
    	}
    }

输出结果：

pool-1-thread-1正在执行。。。
    pool-1-thread-3正在执行。。。
    pool-1-thread-2正在执行。。。
    pool-1-thread-4正在执行。。。
    pool-1-thread-5正在执行。。。

可以看到，我们没有限制线程池的大小，但是它会根据需求而创建线程。

#### 延迟线程池 ####

public class PoolTest {
    	public static void main(String[] args) {
    		ScheduledExecutorService pool=Executors.newScheduledThreadPool(6);
    		for(int i=0;i<4;i++){
    			pool.submit(new MyThread());
    		}
    		
    		pool.schedule(new MyThread(), 1000, TimeUnit.MILLISECONDS);
    		pool.schedule(new MyThread(), 1000, TimeUnit.MILLISECONDS);
    		pool.shutdown();
    	}
    }

输出结果：

pool-1-thread-1正在执行。。。  
pool-1-thread-3正在执行。。。  
pool-1-thread-2正在执行。。。  
pool-1-thread-4正在执行。。。  
pool-1-thread-6正在执行。。。  
pool-1-thread-1正在执行。。。  
       可以明显看到，最后两个线程不是立即执行，而是延迟了1秒在执行的。

#### 单任务延迟线程池 ####

public class PoolTest {
    	public static void main(String[] args) {
    		ScheduledExecutorService pool=Executors.newSingleThreadScheduledExecutor();
    		for(int i=0;i<4;i++){
    			pool.submit(new MyThread());
    		}
    		
    		pool.schedule(new MyThread(), 1000, TimeUnit.MILLISECONDS);
    		pool.schedule(new MyThread(), 1000, TimeUnit.MILLISECONDS);
    		pool.shutdown();
    	}
    }

上面我们使用的是JDK帮我封装好的线程池，我们也可以自己定义线程池，查看源码，我们发现，Excutors里面的获得线程的静态方法，内部都是调用ThreadPoolExecutor的构造方法。比如：

public static ExecutorService newFixedThreadPool(int nThreads, ThreadFactory threadFactory) {
            return new ThreadPoolExecutor(nThreads, nThreads,
                                          0L, TimeUnit.MILLISECONDS,
                                          new LinkedBlockingQueue<Runnable>(),
                                          threadFactory);
        }

可以看到，它是通过调用ThreadPoolExecutor的构造方法来返回一个线程池的。所以，我们也可以自己手动的调用ThreadPoolExecutor的各种构造方法，来定义自己的线程池规则，不过一般情况下，使用自带的线程池就够了，不需要自己来实现。

自定义连接池稍微麻烦些，不过通过创建的ThreadPoolExecutor线程池对象，可以获取到当前线程池的尺寸、正在执行任务的线程数、工作队列等等。

原文链接： [http://blog.csdn.net/lonelyroamer/article/details/7993637][http_blog.csdn.net_lonelyroamer_article_details_7993637]

[http_blog.csdn.net_lonelyroamer_article_details_7993637]: http://blog.csdn.net/lonelyroamer/article/details/7993637