线程池主要处理流程
1.线程池判断核心线程是否已经满了,否 则会创建线程执行任务,是 进入下一个流程
2.线程池判断工作队列是否满了,否 把将要执行的任务加入队列,是 进入下一个流程
3.线程池判断线程池是否满了,否 创建线程执行任务,是进入下一个流程
4.线程池满了,按照策略处理无法执行的任务
项目中的实战
public class ExecutorSupport {
/**cpu个数
*/
private static final int CPU_COUNT = Runtime.getRuntime().availableProcessors();
/**
* 线程池运行的核心线程数
*/
private static final int CORE_POOL_SIZE = Math.max(2, Math.min(CPU_COUNT - 1, 4));
/**
* 线程池最大线程数
*/
private static final int MAXIMUM_POOL_SIZE = CPU_COUNT * 2 + 1;
/**
* 线程空闲后的存活时长
*/
private static final int KEEP_ALIVE = 3;
/**
* 采用ThreadFactory管理线程
*/
private static final ThreadFactory sThreadFactory = new ThreadFactory() {
/**
* 线程index
*/
private final AtomicInteger mCount = new AtomicInteger(1);
/**
* {@inheritDoc}
*/
@Override
public Thread newThread(Runnable r) {
return new Thread(r, "Framework lib Thread #" + mCount.getAndIncrement());
}
};
/**
* 提交到线程池的Runnable队列
*/
private static final BlockingQueue<Runnable> sPoolWorkQueue =
new LinkedBlockingQueue<Runnable>(10);
/**
* 线程池
*/
private static final ThreadPoolExecutor sExecutor
= new ThreadPoolExecutor(CORE_POOL_SIZE, MAXIMUM_POOL_SIZE, KEEP_ALIVE,
TimeUnit.SECONDS, sPoolWorkQueue, sThreadFactory);
/**
* 获取线程池
* @return 线程池
*/
public static Executor getExecutor() {
return sExecutor;
}
/**
* 关闭线程池
*/
public static void shutdown() {
if (!sExecutor.isShutdown()) {
sExecutor.shutdown();
}
}
}
使用方式
ExecutorSupport.getExecutor().execute(new Runnable() {
@Override
public void run() {
// doSomething();
}
}
网友评论