前言

在 Java 诞生之初是没有线程池的概念的,而是先有线程,随着线程数的不断增加,人们发现需要一个专门的类来管理它们,于是才诞生了线程池。

本文来学习下初识下线程池的知识。

走进线程池

为什么需要线程池

在之前我们没有线程池的时候,每发布一个任务就需要创建一个新的线程,这样在任务少时是没有问题的。如下代码所示:

1
2
3
4
5
6
7
8
9
10
11
12
public class ThreadPoolTest {
static class Task implements Runnable{
@Override
public void run() {
System.out.println("当前线程名字:"+Thread.currentThread().getName());
}
}
public static void main(String[] args) {
Thread thread = new Thread(new Task());
thread.start();
}
}

打印结果:

当前线程名字:Thread-0

在这段代码中,我们发布了一个新的任务并放入子线程中,然后启动子线程执行任务,这时的任务也非常简单,只是打印出当前线程的名字,这种情况下,打印结果显示 Thread-0,即我们当前子线程的默认名字。

我们来看一下任务执行流程,如图所示,主线程调用 start() 方法,启动了一个 t0 的子线程。这是在一个任务的场景下,随着我们的任务增多,比如现在有 10 个任务了,那么我们就可以使用 for 循环新建 10 个子线程,如代码所示:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
public class ThreadPoolTest {
static class Task implements Runnable{

@Override
public void run() {
System.out.println("当前线程名字:"+Thread.currentThread().getName());
}
}
public static void main(String[] args) {
for (int i = 0; i < 10; i++) {
Thread thread = new Thread(new Task());
thread.start();
}

}
}

打印结果:

1
2
3
4
5
6
7
8
9
10
>当前线程名字:Thread-0
>当前线程名字:Thread-4
>当前线程名字:Thread-6
>当前线程名字:Thread-1
>当前线程名字:Thread-2
>当前线程名字:Thread-5
>当前线程名字:Thread-7
>当前线程名字:Thread-8
>当前线程名字:Thread-3
>当前线程名字:Thread-9

而且每次的执行结果顺序都是不一样的,数字小的线程不一定在数字大的前面,比如Thread-6在Thread-1的前面。这是因为,虽然 Thread-1 比 Thread-6 先执行 start 方法,但是这并不代表 Thread-1就会先运行,运行的顺序取决于线程调度器,有很大的随机性,这是需要我们注意的地方。

我们再看来下线程的执行流程,如图所示,主线程通过 for 循环创建了 t0~t9 这 10 个子线程,它们都可以正常的执行任务,但如果此时我们的任务量突然飙升到 10000 会怎么样?我们先来看看依然用 for 循环的实现方式:

1
2
3
4
 for (int i = 0; i < 10000; i++) {
Thread thread = new Thread(new Task());
thread.start();
}

如图所示,我们创建了 10000 个子线程,而 Java 程序中的线程与操作系统中的线程是一一对应的,此时假设线程中的任务需要一定的耗时才能够完成,便会产生很大的系统开销与资源浪费。

创建线程时会产生系统开销,并且每个线程还会占用一定的内存等资源,更重要的是我们创建如此多的线程也会给稳定性带来危害,因为每个系统中,可创建线程的数量是有一个上限的,不可能无限的创建。

线程执行完需要被回收,大量的线程又会给垃圾回收带来压力。但我们的任务确实非常多,如果都在主线程串行执行,那效率也太低了,那应该怎么办呢?

于是便诞生了线程池来平衡线程与系统资源之间的关系。

线程池解决的问题

上面提到手动创建线程主要有如下两个问题:

  1. 反复创建线程系统开销比较大,每个线程创建和销毁都需要时间,如果任务比较简单,那么就有可能导致创建和销毁线程消耗的资源比线程执行任务本身消耗的资源还要大。
  2. 过多的线程会占用过多的内存等资源,还会带来过多的上下文切换,同时还会导致系统不稳定。

针对上面两个问题,线程池分别有如下解决措施:

  1. 针对反复创建线程开销大的问题,线程池用一些固定的线程一直保持工作状态并反复执行任务。

  2. 针对过多线程占用太多内存资源的问题,解决思路更直接,线程池会根据需要创建线程,控制线程的总数量,避免占用过多内存资源。

使用线程池

线程池就好比一个池塘,池塘里的水是有限且可控的,比如我们选择线程数固定数量的线程池,假设线程池有 5 个线程,但此时的任务大于 5 个,线程池会让余下的任务进行排队,而不是无限制的扩张线程数量,保障资源不会被过度消耗。如代码所示,我们往 5 个线程的线程池中放入 10000 个任务并打印当前线程名字,结果会是怎么样呢?

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
public class ThreadPoolTest {
static class Task implements Runnable{

@Override
public void run() {
System.out.println("当前线程名字:"+Thread.currentThread().getName());
}
}
public static void main(String[] args) {
ExecutorService executorService = Executors.newFixedThreadPool(5);
for (int i = 0; i < 10000; i++) {
executorService.submit(new Task());
}

System.out.println(Thread.currentThread().getName());
}
}

打印结果:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
>main
>当前线程名字:pool-1-thread-4
>当前线程名字:pool-1-thread-4
>当前线程名字:pool-1-thread-4
>当前线程名字:pool-1-thread-5
>当前线程名字:pool-1-thread-5
>当前线程名字:pool-1-thread-5
>当前线程名字:pool-1-thread-5
>当前线程名字:pool-1-thread-1
>当前线程名字:pool-1-thread-4
>当前线程名字:pool-1-thread-1
>当前线程名字:pool-1-thread-5
>当前线程名字:pool-1-thread-2
>当前线程名字:pool-1-thread-3
>当前线程名字:pool-1-thread-2
>当前线程名字:pool-1-thread-5
>当前线程名字:pool-1-thread-1
>当前线程名字:pool-1-thread-4
>当前线程名字:pool-1-thread-1
>当前线程名字:pool-1-thread-5
>当前线程名字:pool-1-thread-2
>当前线程名字:pool-1-thread-3
>当前线程名字:pool-1-thread-2
>当前线程名字:pool-1-thread-5
>当前线程名字:pool-1-thread-1
>
>.......

如打印结果所示,打印的线程名始终在 pool-1-thread-1~5 之间变化,并没有超过这个范围,也就证明了线程池不会无限制地扩张线程的数量,始终是这5个线程在工作。

执行流程如图所示,首先创建了一个线程池,线程池中有 5 个线程,然后线程池将 10000 个任务分配给这 5 个线程,这 5 个线程反复领取任务并执行,直到所有任务执行完毕,这就是线程池的思想。

使用线程池的好处

使用线程池有以下几点好处:

  1. 线程池可以解决线程生命周期的系统开销问题,同时还可以加快响应速度。因为线程池中的线程是可以复用的,我们只用少量的线程去执行大量的任务,这就大大减小了线程生命周期的开销。而且线程通常不是等接到任务后再临时创建,而是已经创建好时刻准备执行任务,这样就消除了线程创建所带来的延迟,提升了响应速度,增强了用户体验。
  2. 线程池可以统筹内存和 CPU 的使用,避免资源使用不当。线程池会根据配置和任务数量灵活地控制线程数量,不够的时候就创建,太多的时候就回收,避免线程过多导致内存溢出,或线程太少导致 CPU 资源浪费,达到了一个完美的平衡。
  3. 线程池可以统一管理资源。比如线程池可以统一管理任务队列和线程,可以统一开始或结束任务,比单个线程逐一处理任务要更方便、更易于管理,同时也有利于数据统计,比如我们可以很方便地统计出已经执行过的任务的数量。

总结

我们知道了线程池解决的痛点,以及线程池比以前手动创建线程有哪些好处。