线程池
为什么要使用线程池?
线程的创建、销毁会增加系统资源的开销,程序性能的降低。
为了避免频繁的创建、销毁资源。我们可以创建一个池子,里面放着 N 个线程,需要使用线程则可以从线程池里边获取,使用完毕后将线程再放回线程池中以便达到线程的重用。
线程池的原理
举例:
线程池里边分配 3个线程,当有4个任务需要执行时,先分配 3个线程去执行任务,第4个任务等待,直到3个线程中的某个线程中的任务执行完毕后,空闲的线程重新回到线程池,此时再讲任务4分配给空闲的线程去执行。
将任务提交给线程池,由线程池分配线程、运行任务,并在当前任务结束后复用线程。
创建线程池
常用的线程池接口和类
- Executor :线程池顶级接口
- ExecutorService :线程池接口, 通过 submit(Runnable task)提交任务
- Executors :工厂类,通过此类可以获取一个线程池
Executors 类
newFixedThreadPool(int nThreads) 方法,获取固定数量线程池
newCachedThreadPool 方法, 动态获取数量的线程池, 如不够则新创建,没有上限
线程池基本使用1
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class ThreadDemo2 {
public static void main(String[] args) {
// 1. 创建线程池
ExecutorService es = Executors.newFixedThreadPool(4);
// 2. 创建任务
Runnable r = new Runnable() {
private int ticker = 100;
@Override
public void run() {
while (true) {
if (ticker <= 0) {
break;
}
System.out.println(Thread.currentThread().getName() + "卖了第 " + ticker + "张票");
ticker--;
}
}
};
// 3. 提交任务
for (int i = 0; i < 4; i++) {
es.submit(r);
}
// 4. 关闭线程池 shutdown方法等待所有任务执行完毕后关闭线程池, 而 shutdownNow方法不等待任务执行完毕,直接关闭线程池
es.shutdown();
}
}
补充:
Executors.newFixedThreadPool(4) 创建固定个数的线程池;
Executors.newCachedThreadPool(); 创建缓冲线程池,线程数量根据任务决定。
Executors.newSingleThreadExecutor(); 创建单线程的线程池, 线程数量为1
Executors.newScheduledThreadPool(4); 创建调度线程的线程池