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

时间：2022-04-02 19:12:19

线程池使用场景？

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

 Java线程池使用

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

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

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

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

又如：

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

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

还有：

?
1
2
3
4
5
6
7
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线程池的简单使用方法实例教程

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

?
1
2
3
4
5
6
7
8
9
10
11
12
13
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线程池的简单使用的文章就介绍到这了,更多相关Java线程池使用内容请搜索服务器之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持服务器之家！

原文链接：https://juejin.cn/post/7014786840502730765

标签：

相关文章