Java线程池使用 Java线程池的简单使用方法实例教程

线程池使用场景？

java中经常需要用到多线程来处理一些业务，我们非常不建议单纯使用继承Thread或者实现Runnable接口的方式来创建线程，那样势必有创建及销毁线程耗费资源、线程上下文切换问题。同时创建过多的线程也可能引发资源耗尽的风险，这个时候引入线程池比较合理，方便线程任务的管理。java中涉及到线程池的相关类均在jdk1.5开始的java.util.concurrent包中，涉及到的几个核心类及接口包括：Executor、Executors、ExecutorService、ThreadPoolExecutor、FutureTask、Callable、Runnable等。

 Java线程池使用

对于资源池的技术，相信大家早就接触过，比如数据库连接池，常见的有c3p0、dbcp等等，而线程也有对应的池子，称为线程池。

Java提供了Executors类来创建一个线程池，如：

public static void main(String[] args) {
    ExecutorService executorService = Executors.newFixedThreadPool(10);
    Thread thread = new Thread(() -> {
        System.out.println("hello world!");
    });
    executorService.execute(thread);
}

通过newFixedThreadPool()方法可以获得一个指定线程数的线程池。

又如：

public static void main(String[] args) {
    ExecutorService executorService = Executors.newSingleThreadExecutor();
    Thread thread = new Thread(() -> {
        System.out.println("hello world!");
    });
    executorService.execute(thread);
}

通过newSingleThreadExecutor()方法可以获得一个线程数为1的线程池。

还有：

public static void main(String[] args) {
    ExecutorService executorService = Executors.newCachedThreadPool();
    Thread thread = new Thread(() -> {
        System.out.println("hello world!");
    });
    executorService.execute(thread);
}

通过newCachedThreadPool()方法可以获得一个根据需要创建线程的线程池，它会根据任务数创建对应数量的线程。

我们发现，通过Executors类能够创建各式各样的线程池，但阿里巴巴Java开发手册并不推荐我们使用Executors类的方式创建线程，而是要自己手动创建：

那如何手动创建线程池呢？

public static void main(String[] args) {
    ThreadPoolExecutor executor = new ThreadPoolExecutor(
            5,
            10,
            5L,
            TimeUnit.SECONDS,
            new ArrayBlockingQueue<>(3),
            Executors.defaultThreadFactory(),
            new ThreadPoolExecutor.CallerRunsPolicy());
    executor.execute(() -> {
        System.out.println("hello world");
    });
}

构造ThreadPoolExecutor对象即可得到一个线程池，但需要指定七个参数，分别如下：

1. corePoolSize：核心线程数
2. maximumPoolSize：最大线程数
3. keepAliveTime：空闲时间
4. unit：空闲时间单位
5. workQueue：任务队列
6. threadFactory：创建线程的工厂
7. handler：饱和策略

其中核心线程数表示线程池中最核心的线程，它们在任何情况下都不会被回收，而是等待任务的到来，最大线程数是线程池能够创建的最大线程数，空闲时间表示某个非核心线程在等待空闲时间后仍然没有任务执行，该线程便会被回收，创建线程的工厂用于指定创建线程的方式，一般默认即可，饱和策略表示当线程池达到最大线程数后，超出的任务应该如何进行处理。

举一个简单的例子，现在有10个任务等待执行，因为我们的核心线程数为5，所以线程池会先创建5个线程用于执行其中的5个任务，剩下的5个任务会被放入任务队列，而任务队列的容量只有3，所以任务队列只能够放下3个任务，剩下的2个任务无法放入队列，线程池就会创建2个非核心线程用于执行它们，若是此时线程池中的线程数达到了最大线程数，则会触发饱和策略，比如这里的CallerRunsPolicy策略，它将直接丢弃掉新的任务。

总结