码迷,mamicode.com
首页 > 编程语言 > 详细

线程池专题(二)

时间:2018-12-28 17:15:31      阅读:232      评论:0      收藏:0      [点我收藏+]

标签:policy   构造   阻塞队列   linked   基于   mic   adf   实现   ros   

1.创建线程池的构造函数:

public ThreadPoolExecutor(int corePoolSize,int maximumPoolSize,long keepAliveTime,TimeUnit unit,BlockingQueue<Runnable> workQueue,ThreadFactory threadFactory,RejectExecutionHandler handler);

corePoolSize:线程池的大小,这个参数跟后面讲述的线程池的实现原理有非常大的关系。在创建了线程池后,默认情况下,线程池中并没有任何线程,而是等待有任务到来才创建线程去执行任务,除非调用了prestartAllCoreThreads()或者prestartCoreThread()方法,从这2个方法的名字就可以看出,是预创建线程的意思,即在没有任务到来之前就创建corePoolSize个线程或者一个线程。默认情况下,在创建了线程池之后,

线程池中的线程数为0,当有任务来之后,就会创建一个线程去执行任务,当线程池中的线程数目达到corePoolSize后,就会把到达的任务放到缓存队列当中;

 

maximumPoolSize:线程池最大线程数,这个参数也是一个非常重要的参数,它表示在线程池中最多能创建多少个线程;

 

keepAliveTime:表示线程没有任务执行时最多保持多久时间会终止。默认情况下,只有当线程池中的线程大于corePoolSize时,keepAliveTime才会起作用,直到线程池中的线程数不大于corePoolSize,即当线程池中的线程数大于corePoolSize时,如果一个线程空闲的时间达到keepAliveTime,则会终止,直到线程池中的线程不超过corePoolSize。但是如果调用了allowCoreThreadTimeOut(boolean)方法,在线程池中的线程不大于corePoolSize时,keepAliveTime参数也会起作用,直到线程池中的线程数为0;

 

unit:参数keepAliveTime的时间单位,有7中取值,在TimeUnit类中有7中静态属性:

       TimeUnit.DAYS;                              //天

       TimeUnit.HOURS;                          //小时

       TimeUnit.MINUTES;                       //分钟

       TimeUnit.SECONDS;                     //秒

       TimeUnit.MILLISECONDS;            //毫秒

       TimeUnit.MICROSECONDS;         //微秒

       TimeUnit.NANOSECONDS;          //纳秒

 

workQueue:一个阻塞队列,用来存储等待执行的任务,workQueue的类型为BlockingQueue<Runnable>,通常可以取下面三种类型:

       ArrayBlockingQueue;基于数组的先进先出队列,此队列创建时必须指定大小;

       LinkedBlockingQueue;基于链表的先进先出队列,如果创建时没有指定此队列大小,则默认为Integer.MAX_VALUE;

       SynchronousQueue;这个队列比较特殊,它不会保存提交的任务,而是将直接新建一个线程来执行新来的任务。

  备注:ArrayBlockingQueue和PriorityBlockingQueue使用较少,一般使用LinkedBlockingQueue和Synchronous.线程池的排队策略与BlockingQueue有关。

 

threadFactory:线程工厂,主要用来创建线程;

 

handler:表示当拒绝处理任务时的策略,有以下四种取值:

       ThreadPoolExecutor.AbortPolicy:丢弃任务并抛出RejectedExecutionException异常。

       ThreadPoolExecutor.DiscardPolicy:也是丢弃任务,但是不抛弃异常。

       ThreadPoolExecutor.DiscardOldestPolicy:丢弃队列最前面的任务,然后重新尝试执行任务(重复此过程)

       ThreadPoolExecutor.CallRunsPolicy:由调用线程处理该任务

 

https://www.cnblogs.com/dolphin0520/p/3932921.html

线程池专题(二)

标签:policy   构造   阻塞队列   linked   基于   mic   adf   实现   ros   

原文地址:https://www.cnblogs.com/blacksmallcat/p/10191579.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!