Java多线程:类ThreadPoolExecutor详解
Java多线程:类ThreadPoolExecutor详解
张升强 发表于4年前
Java多线程:类ThreadPoolExecutor详解
  • 发表于 4年前
  • 阅读 206
  • 收藏 24
  • 点赞 0
  • 评论 1

腾讯云 十分钟定制你的第一个小程序>>>   

1 public ThreadPoolExecutor(int corePoolSize,
2                                       int maximumPoolSize,
3                                       long keepAliveTime,
4                                       TimeUnit unit,
5                                       BlockingQueue<Runnable> workQueue,
6                                       ThreadFactory threadFactory,
7                                       RejectedExecutionHandler handler)

1. 参数解释
corePoolSize:        线程池维护线程的最少数量
maximumPoolSize:线程池维护线程的最大数量
keepAliveTime:      线程池维护线程所允许的空闲时间
unit:                   线程池维护线程所允许的空闲时间的单位
workQueue:          线程池所使用的缓冲队列
handler:               线程池对拒绝任务的处理策略,默认值ThreadPoolExecutor.AbortPolicy()

unit可选的参数为java.util.concurrent.TimeUnit中的几个静态属性:NANOSECONDS、MICROSECONDS、MILLISECONDS、SECONDS。
workQueue常用的是:java.util.concurrent.ArrayBlockingQueue
handler有四个选择:
ThreadPoolExecutor.AbortPolicy()            抛出java.util.concurrent.RejectedExecutionException异常
ThreadPoolExecutor.CallerRunsPolicy()       重试添加当前的任务,他会自动重复调用execute()方法
ThreadPoolExecutor.DiscardOldestPolicy()    抛弃旧的任务
ThreadPoolExecutor.DiscardPolicy()          抛弃当前的任务

2. 方法调用
一个任务通过 execute(Runnable)方法被添加到线程池,任务就是一个Runnable类型的对象,任务的执行方法就是 Runnable类型对象的run()方法。

3. 处理机制
当一个任务通过execute(Runnable)方法欲添加到线程池时:
如果此时线程池中的数量小于corePoolSize,即使线程池中的线程都处于空闲状态,也要创建新的线程来处理被添加的任务。
如果此时线程池中的数量等于corePoolSize,但是缓冲队列 workQueue未满,那么任务被放入缓冲队列。
如果此时线程池中的数量大于corePoolSize,缓冲队列workQueue满,并且线程池中的数量小于maximumPoolSize,建新的线程来处理被添加的任务。
如果此时线程池中的数量大于corePoolSize,缓冲队列workQueue满,并且线程池中的数量等于maximumPoolSize,那么通过 handler所指定的策略来处理此任务。

处理任务的多时:
核心线程corePoolSize、任务队列workQueue、最大线程maximumPoolSize,如果三者都满了,使用handler处理被拒绝的任务。
处理任务的少时:
当线程池中的线程数量大于corePoolSize时,如果某线程空闲时间超过keepAliveTime,线程将被终止。这样,线程池可以动态的调整池中的线程数。

4. 创建线程池的一些方法:
01 public static ExecutorService newFixedThreadPool(int nThreads) {
02     return new ThreadPoolExecutor(nThreads,
03                                 nThreads,
04                                 0L,
05                                 TimeUnit.MILLISECONDS,
06                                 newLinkedBlockingQueue<Runnable>());    
07 }
08  
09 public static ExecutorService newCachedThreadPool() {
10     return new ThreadPoolExecutor(0,
11                                 Integer.MAX_VALUE,
12                                 60L,
13                                 TimeUnit.SECONDS,
14                                 newSynchronousQueue<Runnable>());    
15 }
16  
17 public static ExecutorService newSingleThreadExecutor() {
18     return new FinalizableDelegatedExecutorService(new ThreadPoolExecutor(1,
19                                                                         1,
20                                                                         0L,
21                                                                         TimeUnit.MILLISECONDS,
22                                                                         newLinkedBlockingQueue<Runnable>()));
共有 人打赏支持
粉丝 39
博文 107
码字总数 154023
评论 (1)
×
张升强
如果觉得我的文章对您有用,请随意打赏。您的支持将鼓励我继续创作!
* 金额(元)
¥1 ¥5 ¥10 ¥20 其他金额
打赏人
留言
* 支付类型
微信扫码支付
打赏金额:
已支付成功
打赏金额: