加入收藏 | 设为首页 | 会员中心 | 我要投稿 惠州站长网 (https://www.0752zz.com.cn/)- 办公协同、云通信、物联设备、操作系统、高性能计算!
当前位置: 首页 > 建站 > 正文

关于线程池你不能不知道的东西

发布时间:2019-07-10 02:42:52 所属栏目:建站 来源:儒雅程序员
导读:副标题#e# 前言 平时接触过多线程开发的童鞋应该都或多或少了解过线程池,之前发布的《阿里巴巴 Java 手册》里也有一条: 可见线程池的重要性。 简单来说使用线程池有以下几个目的: 线程是稀缺资源,不能频繁的创建。 解耦作用;线程创建于执行完全分开,方

我通常是按照以下方式关闭线程池的:

  1. long start = System.currentTimeMillis(); 
  2.  for (int i = 0; i <= 5; i++) { 
  3.  pool.execute(new Job()); 
  4.  } 
  5.  pool.shutdown(); 
  6.  while (!pool.awaitTermination(1, TimeUnit.SECONDS)) { 
  7.  LOGGER.info("线程还在执行。。。"); 
  8.  } 
  9.  long end = System.currentTimeMillis(); 
  10.  LOGGER.info("一共处理了【{}】", (end - start)); 

pool.awaitTermination(1, TimeUnit.SECONDS) 会每隔一秒钟检查一次是否执行完毕(状态为 TERMINATED),当从 while 循环退出时就表明线程池已经完全终止了。

SpringBoot 使用线程池

2018 年了,SpringBoot 盛行;来看看在 SpringBoot 中应当怎么配置和使用线程池。

既然用了 SpringBoot ,那自然得发挥 Spring 的特性,所以需要 Spring 来帮我们管理线程池:

  1. @Configuration 
  2. public class TreadPoolConfig { 
  3.  /** 
  4.  * 消费队列线程 
  5.  * @return 
  6.  */ 
  7.  @Bean(value = "consumerQueueThreadPool") 
  8.  public ExecutorService buildConsumerQueueThreadPool(){ 
  9.  ThreadFactory namedThreadFactory = new ThreadFactoryBuilder() 
  10.  .setNameFormat("consumer-queue-thread-%d").build(); 
  11.  ExecutorService pool = new ThreadPoolExecutor(5, 5, 0L, TimeUnit.MILLISECONDS, 
  12.  new ArrayBlockingQueue(5),namedThreadFactory,new ThreadPoolExecutor.AbortPolicy()); 
  13.  return pool ; 
  14.  } 

使用时:

  1. @Resource(name = "consumerQueueThreadPool") 
  2.  private ExecutorService consumerQueueThreadPool; 
  3.  @Override 
  4.  public void execute() { 
  5.  //消费队列 
  6.  for (int i = 0; i < 5; i++) { 
  7.  consumerQueueThreadPool.execute(new ConsumerQueueThread()); 
  8.  } 
  9.  } 

其实也挺简单,就是创建了一个线程池的 bean,在使用时直接从 Spring 中取出即可。

监控线程池

谈到了 SpringBoot,也可利用它 actuator 组件来做线程池的监控。

线程怎么说都是稀缺资源,对线程池的监控可以知道自己任务执行的状况、效率等。

关于 actuator 就不再细说了,感兴趣的可以看看这篇,有详细整理过如何暴露监控端点。

(编辑:惠州站长网)

【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!

推荐文章
    热点阅读