Java通过Executors提供四种线程池,分别为:
newCachedThreadPool创建一个可缓存线程池,如果线程池长度超过处理需要,可灵活回收空闲线程,若无可回收,则新建线程。
newFixedThreadPool 创建一个定长线程池,可控制线程最大并发数,超出的线程会在队列中等待。
newScheduledThreadPool 创建一个定长线程池,支持定时及周期性任务执行。
newSingleThreadExecutor 创建一个单线程化的线程池,它只会用唯一的工作线程来执行任务,保证所有任务按照指定顺序(FIFO, LIFO, 优先级)执行。
newCachedThreadPool:这是我们平时最常用的
Demo Code
public class LiftOff implements Runnable {
protected int count = 10;
private static int taskCount = 0;
private final int id = taskCount++;
public void run() {
while (count-- > 0) {
System.out.println(status());
Thread.yield();
}
}
public String status() {
return "# " +id +" ("+(count>0?count:"LifOff ")+")";
}
public LiftOff(int count) {
this.count = count;
}
public LiftOff() {
}
}
newCachedThreadPool 最常用的线程池
public void isitCacheThreadPool() {
ExecutorService service = Executors.newCachedThreadPool();
for (int i = 0; i < 3; i++) {
service.execute(new LiftOff());
}
service.shutdown();//关闭线程
service.shutdownNow();//强制关闭线程
}
newFixedThreadPool 当确定线程的创建数量之后可以创建有限线程执行器
public void isitFixedRhreadPool() {
int num = 5;
/**当确定线程的创建数量之后可以创建有限线程执行器*/
ExecutorService service = Executors.newFixedThreadPool(num);
for (int i = 0; i < num; i++) {
service.execute(new LiftOff());
}
service.shutdown();
}
newSingleThreadExecutor 任意时刻在线程池中都只有唯一的任务在运行
public void isitSingleThreadPool() {
/**任意时刻在线程池中都只有唯一的任务在运行*/
ExecutorService service = Executors.newSingleThreadExecutor();
for (int i = 0; i < 5; i++) {
service.execute(new LiftOff());
}
service.shutdown();
}
newScheduledThreadPool 定时执行
@Test
public void isitScheduledThreadPool() {
ScheduledExecutorService service = Executors.newScheduledThreadPool(3);
service.scheduleAtFixedRate(new Runnable() {
public void run() {
System.out.println("延迟执行3s");
}
}, 1, 3, TimeUnit.SECONDS);//表示延迟1秒后每3秒执行一次。
}