jdk1.5中在juc包中引入了线程池,其中最常用的ThreadPoolExecutor
它的构造器参数为以下几种:
-
corePoolSIze
-
maximumPoolSize
-
keepAliveTime
-
unit
-
workQueue
PriorityBlockingQueue
ArrayBlockingQueue;
LinkedBlockingQueue;
SynchronousQueue;
DelayedWorkQueue
不同的阻塞队列,任务的排队策略也不同:
(1)直接提交(如SynchronousQueue)
直接提交策略表示线程池不对任务进行缓存。新进任务直接提交给线程池,当线程池中没有空闲线程时,创建一个新的线程处理此任务。这种策略需要线程池具有无限增长的可能性。
Executors.newCachedThreadPool()使用SynchronousQueue创建线程池。
(2)无界队列(如不具有预定义容量的LinkedBlockingQueue)
LinkedBlockingQueue将导致当所有 corePoolSize 线程都忙时新任务在队列中等待。这样,创建的线程就不会超过 corePoolSize。(因此,maximumPoolSize 的值也就无效了。)当每个任务完全独立于其他任务,即任务执行互不影响时,适合于使用无界队列。
Executors.newFixedThreadPool(3)使用LinkedBlockingQueue创建线程池。
Executors.newSingleThreadExecutor()使用LinkedBlockingQueue创建线程池。
(3)有界队列(如ArrayBlockingQueue)
有界队列(如ArrayBlockingQueue)有助于防止资源耗尽当最大线程数有限时,但是可能较难调整和控制。队列大小和最大池大小可能需要相互折衷。
(4)优先级队列(如PriorityBlockingQueue)
(5)DelayedWorkQueue
DelayedWorkQueue是ScheduledThreadPoolExecutor的静态内部类。
Executors.newScheduledThreadPool(3)使用DelayedWorkQueue创建线程池。
- handler:拒绝任务时的策略
ThreadPoolExecutor.AbortPolicy:丢弃任务并抛出RejectedExecutionException异常。
ThreadPoolExecutor.DiscardPolicy:也是丢弃任务,但是不抛出异常。
ThreadPoolExecutor.DiscardOldestPolicy:丢弃队列最前面的任务,然后重新尝试执行任务(重复此过程)
ThreadPoolExecutor.CallerRunsPolicy:由调用主线程处理该任务,线程池中的线程已经耗尽
网友评论