Executors的4种快捷创建线程池的方法
Java通过Executors工厂类提供了4种快捷创建线程池的方法,具体 如表1-1所示。 ![在这里插入图片描述](https://img-blog.csdnimg.cn/91f7a5a44d8a4d3d9c008856c1f248cf.png) 1.newSingleThreadExecutor创建“单线程化线程池” 该方法用于创建一个“单线程化线程池”,也就是只有一个线程的线 程池,所创建的线程池用唯一的工作线程来执行任务,使用此方法创建 的线程池能保证所有任务按照指定顺序(如FIFO)执行。 调用Executors.newSingleThreadExecutor()快捷工厂方法创建一个“单 线程化线程池”的测试用例,其代码如下:
public class CreateThreadPoolDemo {
public static final int SLEEP_GAP = 500;
public static void main(String[] args) throws InterruptedException {
ExecutorService executorService = Executors.newSingleThreadExecutor();
for (int i = 0; i < 5; i++) {
executorService.execute(new TargetTask());
executorService.submit(new TargetTask());
}
Thread.sleep(SLEEP_GAP);
executorService.shutdown();
}
static class TargetTask implements Runnable {
static AtomicInteger taskNo = new AtomicInteger(1);
private String taskName;
public TargetTask() {
taskName="task-"+taskNo.get();
taskNo.incrementAndGet();
}
@SneakyThrows
@Override
public void run() {
System.out.println("任务"+taskName+" is running");
Thread.sleep(SLEEP_GAP);
System.out.println("任务"+taskName+"运行结束");
}
}
}
![在这里插入图片描述](https://img-blog.csdnimg.cn/0b97c7f726134e3cb4e19dde4adb2968.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBAWXVfQ2hlbl9f,size_11,color_FFFFFF,t_70,g_se,x_16) 从以上输出中可以看出,该线程池有以下特点: (1)单线程化的线程池中的任务是按照提交的次序顺序执行的。 (2)池中的唯一线程的存活时间是无限的。 (3)当池中的唯一线程正繁忙时,新提交的任务实例会进入内部 的阻塞队列中,并且其阻塞队列是无界的。 总体来说,单线程化的线程池所适用的场景是:任务按照提交次 序,一个任务一个任务地逐个执行的场景。 以上用例在最后调用shutdown()方法来关闭线程池。执行shutdown() 方法后,线程池状态变为SHUTDOWN,此时线程池将拒绝新任务,不 能再往线程池中添加新任务,否则会抛出RejectedExecutionException异 常。此时,线程池不会立刻退出,直到添加到线程池中的任务都已经处 理完成才会退出。还有一个与shutdown()类似的方法,叫作 shutdownNow(),执行shutdownNow()方法后,线程池状态会立刻变成 STOP,并试图停止所有正在执行的线程,并且不再处理还在阻塞队列 中等待的任务,会返回那些未执行的任务。
|