千家信息网

如何使用Java线程池

发表于:2024-11-15 作者:千家信息网编辑
千家信息网最后更新 2024年11月15日,本篇内容主要讲解"如何使用Java线程池",感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习"如何使用Java线程池"吧!目录线程池使用场景?Java线程池使用总
千家信息网最后更新 2024年11月15日如何使用Java线程池

本篇内容主要讲解"如何使用Java线程池",感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习"如何使用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策略,它将直接丢弃掉新的任务。

到此,相信大家对"如何使用Java线程池"有了更深的了解,不妨来实际操作一番吧!这里是网站,更多相关内容可以进入相关频道进行查询,关注我们,继续学习!

0