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

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

线程池

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

与数据库连接池类似的是,线程池在系统启动时即创建大量空闲的线程,程序将一个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中Flux类的使用方法和示例代码

    Java中Flux类的使用方法和示例代码

    在Java编程中Flux是一种处理响应式编程的库,它提供了一种异步数据流处理的方式,这篇文章主要给大家介绍了关于Java中Flux类的使用方法和示例代码,文中通过代码介绍的非常详细,需要的朋友可以参考下
    2024-08-08
  • java 安全ysoserial URLDNS利用链分析

    java 安全ysoserial URLDNS利用链分析

    这篇文章主要为大家介绍了java 安全ysoserial URLDNS利用链分析,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2022-10-10
  • Spring Boot Admin(监控工具)的使用

    Spring Boot Admin(监控工具)的使用

    今天我们将会讲解一个优秀的监控工具Spring Boot Admin。 它采用图形化的界面,让我们的Spring Boot管理更加简单,需要的朋友可以参考下
    2020-02-02
  • Spring Boot和Kotlin的无缝整合与完美交融

    Spring Boot和Kotlin的无缝整合与完美交融

    这篇文章主要给大家介绍了关于Spring Boot和Kotlin的无缝整合与完美交融的相关资料,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2018-06-06
  • Spring Boot RabbitMQ 延迟消息实现完整版示例

    Spring Boot RabbitMQ 延迟消息实现完整版示例

    本篇文章主要介绍了Spring Boot RabbitMQ 延迟消息实现完整版示例,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2018-05-05
  • Java算法实战之排一亿个随机数

    Java算法实战之排一亿个随机数

    我们在生活中经常遇见一些这样的需求,随机点名、公司年会抽奖、微信拼手气红包等,还有一些游戏比如打地鼠小游戏、俄罗斯方块等,这些场景中都会用到一种算法:随机,这篇文章主要给大家介绍了关于Java算法实战之排一亿个随机数的相关资料,需要的朋友可以参考下
    2021-11-11
  • SpringBoot + Redis如何解决重复提交问题(幂等)

    SpringBoot + Redis如何解决重复提交问题(幂等)

    在开发中,一个对外暴露的接口可能会面临瞬间的大量重复请求,本文就介绍了SpringBoot + Redis如何解决重复提交问题,具有一定的参考价值,感兴趣的可以了解一下
    2021-12-12
  • Java毕业设计实战之在线蛋糕销售商城的实现

    Java毕业设计实战之在线蛋糕销售商城的实现

    这是一个使用了java+JSP+Springboot+maven+mysql+ThymeLeaf+FTP开发的在线蛋糕销售商城,是一个毕业设计的实战练习,具有线上蛋糕商城该有的所有功能,感兴趣的朋友快来看看吧
    2022-01-01
  • Java编译错误问题:需要class,interface或enum

    Java编译错误问题:需要class,interface或enum

    这篇文章主要介绍了Java编译错误问题:需要class,interface或enum,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2024-02-02
  • IDEA 隐藏DEBUG日志的解决方法

    IDEA 隐藏DEBUG日志的解决方法

    IDEA 打印太多的DEBUG日志,看起来很烦,有没有办法隐藏日志,网上找了一圈,没有谁写的靠谱的,下面小编给大家分享下IDEA 如何隐藏DEBUG日志,需要的朋友可以参考下
    2022-09-09

最新评论