线程池核心参数
ThreadPoolExecutor(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
BlockingQueue<Runnable> workQueue,
ThreadFactory threadFactory,
RejectedExecutionHandler handler)
1）corePoolSize（线程池基本大小）
2）maximumPoolSize（线程池最大数量）
3）keepAliveTime（空闲线程活动保持时间）：线程池工作线程空闲后，保持存活时间
4）TimeUnit（时间单位）
5）workQueue（任务队列）：用于保存等待执行任务的阻塞队列
1、ArrayBlockQueue
2、LinkedBlockQueue
3、SynchronousQueue(不存储元素阻塞队列)
4、PriorityBlockingQueue(优先级无限阻塞队列)
6） threadFactory(线程工厂)
7） handler（饱和策略）
1、AbortPolicy:直接抛出异常
2、CallerRunsPolicy:调用者所在线程来运行任务
3、DiscardOrderestPolicy:丢队列最近一个任务，并执行
4、DiscardPolicy:不处理，丢掉
四种线程池
固定线程池 newFixedThreadPool
缓存线程池 newCachedThreadPool
单个线程 newSingleThreadExecutor
定时线程池 newScheduledThreadPool
//固定线程池
public static ExecutorService newFixedThreadPool(int nThreads) {
return new ThreadPoolExecutor( nThreads, nThreads,
0L, TimeUnit.MILLISECONDS,
new LinkedBlockingQueue<Runnable>() );
}
//缓存线程池
public static ExecutorService newCachedThreadPool() {
return new ThreadPoolExecutor( 0, Integer.MAX_VALUE,
60L, TimeUnit.SECONDS,
new SynchronousQueue<Runnable>() );
}
//单个线程池
public static ExecutorService newSingleThreadExecutor() {
return new ThreadPoolExecutor( 1, 1,
0L, TimeUnit.MILLISECONDS,
new LinkedBlockingQueue<Runnable>() );
}
//定时线程池
public static ExecutorService newScheduledThreadPoolExecutor(int corePoolSize) {
return new ThreadPoolExecutor( corePoolSize, Integer.MAX_VALUE, 0, NANOSECONDS,
new ScheduledThreadPoolExecutor.DelayedWorkQueue() );
}
任务性质分类
获得cpu个数
int cpu = Runtime.getRuntime().availableProcessors();
CPU密集型：Ncpu+1
IO密集型：2* Ncpu
混合型：线程池分解
