线程池原理与实战

Java通过Executors工厂类提供了4种快捷创建线程池的方法，具体 如表1-1所示。

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+"运行结束");
        }
    }
}

从以上输出中可以看出，该线程池有以下特点：
（1）单线程化的线程池中的任务是按照提交的次序顺序执行的。 （2）池中的唯一线程的存活时间是无限的。 （3）当池中的唯一线程正繁忙时，新提交的任务实例会进入内部 的阻塞队列中，并且其阻塞队列是无界的。
总体来说，单线程化的线程池所适用的场景是：任务按照提交次 序，一个任务一个任务地逐个执行的场景。
以上用例在最后调用shutdown()方法来关闭线程池。执行shutdown() 方法后，线程池状态变为SHUTDOWN，此时线程池将拒绝新任务，不 能再往线程池中添加新任务，否则会抛出RejectedExecutionException异 常。此时，线程池不会立刻退出，直到添加到线程池中的任务都已经处 理完成才会退出。还有一个与shutdown()类似的方法，叫作 shutdownNow()，执行shutdownNow()方法后，线程池状态会立刻变成 STOP，并试图停止所有正在执行的线程，并且不再处理还在阻塞队列 中等待的任务，会返回那些未执行的任务。