Java 线程池_动力节点Java学院整理

线程池

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

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

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

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

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

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

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有几个重要的方法：

更详细的参考JDK API文档。

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

三、ScheduleExecutorService类

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

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

下面看看线程池的简单使用：

1、固定大小的线程池：

package com.bjpowernode.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个线程，这样就减少了并发线程的数量。

2、单任务线程池：

 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正在执行。。。 

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

3、创建可变尺寸的线程池

 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正在执行。。。 

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

4、延迟线程池

 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秒在执行的。

5、单任务延迟线程池

 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的各种构造方法，来定义自己的线程池规则，不过一般情况下，使用自带的线程池就够了，不需要自己来实现。

以上所述是小编给大家介绍的Java 线程池，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对网站的支持！

# java  # 线程池  # Java 线程池ExecutorService详解及实例代码  # Java 线程池详解及实例代码  # Java Socket编程实例（三）- TCP服务端线程池  # Java线程池的几种实现方法及常见问题解答  # 四种Java线程池用法解析  # Java 线程池详解  # 可以看到  # 都是  # 创建一个  # 自己的  # 池中  # 的是  # 几个  # 就会  # 很好  # 尤其是  # 较高  # 因为它  # 连接池  # 涉及到  # 在这种情况下  # 方法来  # 很短  # 控制系统  # 小编  # 多线程 

相关文章： 如何用wdcp快速搭建高效网站？  怎么制作网站设计模板图片,有电商商品详情页面的免费模板素材网站推荐吗？  建站主机CVM配置优化、SEO策略与性能提升指南  枣阳网站制作,阳新火车站打的到仙岛湖多少钱？  制作宣传网站的软件,小红书可以宣传网站吗？  建站之星各版本价格是多少？  深圳网站制作公司好吗,在深圳找工作哪个网站最好啊？  公司网站制作需要多少钱,找人做公司网站需要多少钱？  如何用美橙互联一键搭建多站合一网站？  简历在线制作网站免费版,如何创建个人简历？  西安大型网站制作公司,西安招聘网站最好的是哪个？  如何通过智能用户系统一键生成高效建站方案？  建站主机选哪家性价比最高？  网站制作话术技巧,网站推广做的好怎么话术？  做企业网站制作流程,企业网站制作基本流程有哪些？  建站之星如何实现网站加密操作？  广德云建站网站建设方案与建站流程优化指南  如何用景安虚拟主机手机版绑定域名建站？  如何通过VPS搭建网站快速盈利？  C++如何将C风格字符串（char*）转换为std::string？（代码示例）  企业在线网站设计制作流程,想建设一个属于自己的企业网站，该如何去做？  如何在IIS管理器中快速创建并配置网站？  中山网站制作网页,中山新生登记系统登记流程？  建站之星如何快速更换网站模板？  重庆市网站制作公司,重庆招聘网站哪个好？  如何在阿里云香港服务器快速搭建网站？  网站制作公司排行榜,抖音怎样做个人官方网站  网站好制作吗知乎,网站开发好学吗？有什么技巧？  孙琪峥织梦建站教程如何优化数据库安全？  c++怎么使用类型萃取type_traits_c++ 模板元编程类型判断【方法】  全景视频制作网站有哪些,全景图怎么做成网页？  如何通过虚拟机搭建网站？详细步骤解析  盘锦网站制作公司,盘锦大洼有多少5G网站？  如何在阿里云部署织梦网站？  如何基于PHP生成高效IDC网络公司建站源码？  c# 在高并发下使用反射发射（Reflection.Emit）的性能  深圳网站制作培训,深圳哪些招聘网站比较好？  兔展官网 在线制作,怎样制作微信请帖？  如何用手机制作网站和网页,手机移动端的网站能制作成中英双语的吗？  Android使用GridView实现日历的简单功能  建站之星2.7模板：企业网站建设与h5定制设计专题  建站之星如何一键生成手机站？  西安制作网站公司有哪些,西安货运司机用的最多的app或者网站是什么？  香港代理服务器配置指南：高匿IP选择、跨境加速与SEO优化技巧  建站之星客服服务时间及联系方式如何？  制作网站外包平台,自动化接单网站有哪些？  制作网站的软件免费下载,免费制作app哪个平台好？  php能控制zigbee模块吗_php通过串口与cc2530 zigbee通信【介绍】  rsync同步时出现rsync: failed to set times on “xxxx”: Operation not permitted  javascript中的try catch异常捕获机制用法分析