Executors类里面提供了一些静态工厂,生成一些常用的线程池。
- newSingleThreadExecutor:创建一个单线程的线程池。这个线程池只有一个线程在工作,也就是相当于单线程串行执行所有任务。如果这个唯一的线程因为异常结束,那么会有一个新的线程来替代它。此线程池保证所有任务的执行顺序按照任务的提交顺序执行。
- newFixedThreadPool:创建固定大小的线程池。每次提交一个任务就创建一个线程,直到线程达到线程池的最大大小。线程池的大小一旦达到最大值就会保持不变,如果某个线程因为执行异常而结束,那么线程池会补充一个新线程。
- newCachedThreadPool:创建一个可缓存的线程池。如果线程池的大小超过了处理任务所需要的线程,那么就会回收部分空闲(60秒不执行任务)的线程,当任务数增加时,此线程池又可以智能的添加新线程来处理任务。此线程池不会对线程池大小做限制,线程池大小完全依赖于操作系统(或者说JVM)能够创建的最大线程大小。
- newScheduledThreadPool:创建一个大小无限的线程池。此线程池支持定时以及周期性执行任务的需求。
- newSingleThreadScheduledExecutor:创建一个单线程的线程池。此线程池支持定时以及周期性执行任务的需求。
Executors.newFixedThreadPool(2) 可以创建固定数目的线程。如果线程执行完成,可以重新执行另外一个任务。
public class ThreadPoolDemo { public static void main(String[] args) {
ExecutorService es = Executors.newFixedThreadPool(2);
es.execute(new PrintChar(‘a’,20)); es.execute(new PrintChar(‘b’,20));
es.shutdown(); } }
Executors.newCachedThreadPool() 每次提交任务,如果线程池中没有空闲线程,就创建新线程。适用于执行时间短暂的任务。 public class ExecutorUsage { public static void main(String[] args) {
ThreadPoolExecutor executor = (ThreadPoolExecutor)Executors.newCachedThreadPool();
for(int i=0;i<10;i++){
executor.execute(new Task(“Task “+i));
System.out.printf(“Server: Pool Size: %d\n”,
executor.getPoolSize());
System.out.printf(“Server: Active Count: %d\n”,
executor.getActiveCount());
System.out.printf(“Server: Completed Tasks: %d\n”,
executor.getCompletedTaskCount());
}
executor.shutdown();
}
}
ScheduledThreadPoolExecutor
schedule (Runnable task, long delay, TimeUnit timeunit) 推迟一定时间再执行线程,只执行一次
scheduleAtFixedRate (Runnable, long initialDelay, long period, TimeUnit timeunit) period 从上一线程开始计算
scheduleWithFixedDelay (Runnable, long initialDelay, long period, TimeUnit timeunit) period 以上一线程结束计算