线程池从功能上来看,就是一个任务管理器。在Java中,Executor接口是线程池的根接口,其中只包含一个方法:
void execute(Runnable command); // 执行任务
ExecutorService继承了Executor接口,提供了一些线程池的基础方法:
void shutdown(); // 关闭线程池(不接受新任务,但是旧任务会执行) List<Runnable> shutdownNow(); // 关闭线程池,返回待执行任务 boolean isShutdown(); // 线程池是否会关闭 boolean isTerminated(); // 关闭之前所有任务是否被关闭。(必须先执行过shutdown) ....
再往下是两种线程池的实现:ThreadPoolExecutor和ForkJoinPool。ThreadPoolExecutor中维护了一个BlockingQueue阻塞队列保存所有的待执行任务,而ForkJoinPool中每一个线程都有自己的BlockingQueue用来存储任务。
在ThreadPoolExecutor的构造方法中,需要提供几个参数:corePoolSize、maximumPoolSize、keepAliveTime、BlockingQueue、RejectedExecutionHandler。其中corePoolSize表示当前线程池维护几个线程,maximumPoolSize表示允许的最大线程数。keepAliveTime表示如果当前线程数在
corePoolSize和maximumPoolSize之间时,允许在多久时间内保持存活等待新任务。BlockingQueue是保存任务的阻塞队列,RejectedExecutionHandler是不同的拒绝策略。
public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, RejectedExecutionHandler handler) { this(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, Executors.defaultThreadFactory(), handler); }