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

线程的使用在java中占有极其重要的地位,在jdk1.4极其之前的jdk版本中,关于线程池的使用是极其简陋的,在jdk1.5之后这一情况有了很大的改,这篇文章主要给大家介绍了关于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类的方式创建线程，而是要自己手动创建：

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

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

				?

									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对象即可得到一个线程池，但需要指定七个参数，分别如下：

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

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

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