网创优客建站品牌官网
为成都网站建设公司企业提供高品质网站建设
热线:028-86922220
成都专业网站建设公司

定制建站费用3500元

符合中小企业对网站设计、功能常规化式的企业展示型网站建设

成都品牌网站建设

品牌网站建设费用6000元

本套餐主要针对企业品牌型网站、中高端设计、前端互动体验...

成都商城网站建设

商城网站建设费用8000元

商城网站建设因基本功能的需求不同费用上面也有很大的差别...

成都微信网站建设

手机微信网站建站3000元

手机微信网站开发、微信官网、微信商城网站...

建站知识

当前位置:首页 > 建站知识

如何通过ThreadPoolExecutor的方式创建线程池

如何通过ThreadPoolExecutor的方式创建线程池,针对这个问题,这篇文章详细介绍了相对应的分析和解答,希望可以帮助更多想解决这个问题的小伙伴找到更简单易行的方法。

创新互联长期为近千家客户提供的网站建设服务,团队从业经验10年,关注不同地域、不同群体,并针对不同对象提供差异化的产品和服务;打造开放共赢平台,与合作伙伴共同营造健康的互联网生态环境。为西藏企业提供专业的成都网站制作、成都网站设计,西藏网站改版等技术服务。拥有10年丰富建站经验和众多成功案例,为您定制开发。

线程池不建议使用Executors去创建,而是通过ThreadPoolExecutor的方式,这样的处理方式让写的同学更加明确线程池的运行规则,规避资源耗尽的风险。

Executors各个方法的弊端:

  1. newFixedThreadPool 和 newSingleThreadExecutor:
    主要问题是堆积的请求处理队列可能会耗费非常大的内存,甚至OOM。(笔者注:阻塞队列均采用LinkedBlockingQueue)

  2. newCachedThreadPool 和 newScheduledThreadPool:
    主要问题是线程数最大数是Integer.MAX_VALUE,可能会创建数量非常多的线程,甚至OOM。

ThreadPoolExecutor函数

Executors提供了四种创建线程池的方法,实际上Executors的底层也是调用了ThreadPoolExecutor。函数定义如下:

public ThreadPoolExecutor(int corePoolSize,  // 线程池的核心线程数                          
int maximumPoolSize, // 线程池的最大线程数                          
long keepAliveTime, // 当线程数大于核心时,多余的空闲线程等待新任务的存活时间。                          
TimeUnit unit, // keepAliveTime的时间单位                          
ThreadFactory threadFactory, // 线程工厂                          
BlockingQueue workQueue,// 用来储存等待执行任务的队列                          
RejectedExecutionHandler handler // 拒绝策略                          )

线程池运行原理:

如何通过ThreadPoolExecutor的方式创建线程池

函数参数补充说明

  1. workQueue有以下七种选择:

  • ArrayBlockingQueue: 一个由数组结构组成的有界阻塞队列(数组结构可配合指针实现一个环形队列)。

  • LinkedBlockingQueue: 一个由链表结构组成的有界阻塞队列,而在未指明容量时,容量默认为Integer.MAX_VALUE。

  • PriorityBlockingQueue: 一个支持优先级排序的无界阻塞队列,对元素没有要求,可以实现Comparable接口也可以提供Comparator来对队列中的元素进行比较,跟时间没有任何关系,仅仅是按照优先级取任务。

  • DelayQueue: 同PriorityBlockingQueue,也是二叉堆实现的优先级主阻塞队列。要求元素都实现Delayed接口,通过执行时延从队列中提取任务,时间没到任务取不出来。

  • SynchronousQueue: 一个不存储元素的阻塞队列,消费者线程调用take()方法的时候就会发生阻塞,直到有一个生产者线程生产了一个元素,消费者线程就可以拿到这个元素并返回;生产者线程调用put()方法的时候就会发生阻塞,直到有一个消费者线程消费了一个元素,生产者才会返回。

  • LinkedTransferQueue: 它是ConcurrentLinkedQueue、LinkedBlockingQueue和SynchronousQueue的结合体,但是把它用在ThreadPoolExecutor中,和LinkedBlockingQueue行为一致。

  • LinkedBlockingDeque: 使用双向队列实现的双端阻塞队列,双端意味着可以像普通队列一样FIFO(先进先出),可以以像栈一样FILO(先进后出)

  1. handler有以下四种取值:

  • AbortPolicy(默认):丢弃任务并抛出RejectedExecutionException异常。

  • CallerRunsPolicy:由调用线程处理该任务。(例如io操作,线程消费速度没有NIO读取快,可能导致阻塞队列一直增加,此时可以使用这个模式)

  • DiscardPolicy:丢弃任务,但是不抛出异常。 (可以配合这种模式进行自定义的处理方式)

  • DiscardOldestPolicy:丢弃队列最早的未处理任务,然后重新尝试执行任务(重复执行)

关于如何通过ThreadPoolExecutor的方式创建线程池问题的解答就分享到这里了,希望以上内容可以对大家有一定的帮助,如果你还有很多疑惑没有解开,可以关注创新互联行业资讯频道了解更多相关知识。


分享名称:如何通过ThreadPoolExecutor的方式创建线程池
URL分享:http://bjjierui.cn/article/piepsh.html

其他资讯