线程池

1 线程池概念

什么是线程池

一个用来创建和管理线程的容器

JDK.15新特性

为什么要使用线程池

频繁的创建和销毁线程很耗资源，而线程池可以让线程重复执行任务，

提高线程的复用性，从而降低资源消耗

线程池的核心思想

线程复用

线程池的好处

降低的资源的消耗，提供线程的复用性

提高程序的响应速度

提高线程的可管理性

2 线程池的使用

2.1 线程池的创建方式

如何创建线程池(容器)

在JDK1.5之后,Java官方推出了一个类专门用来创建线程池，该类：Executors

通过Executors类提供的静态方法就可以快速创建线程池对象，该方法如下：

public static ExecutorService newFixedThreadPool(int nThreads)

创建线程池并指定线程数量

ExecutorService接口概述

只要是该接口的实现类对象就是一个线程池对象

ExecutorService接口常用方法

Future<?> submit(Runnable task); 提供Runnable任务

Future<T> submit(Callable<T> task); 提交Callable任务

void shutdown(); 销毁线程池,会等待线程池中的任务都执行完毕之后才销毁

List<Runnable> shutdownNow() 立即销毁线程池，如果线程池中的任务还没有开始执行就不会被执行

线程池使用步骤：提交Runnable任务

通过线程池工具类Executors的静态方法创建线程池对象

创建一个类实现Runnable接口并重写run方法：线程任务相关的代码就写在该方法中

调用线程池对象的submit方法提交任务：实现了Runnable接口的实现类对象

调用线程池对象的shutdown方法销毁线程池

2.2 提交任务—Runnable任务

/**

* 自定义Runnable接口实现类

*/

public class RunnableTask implements Runnable {
@Override
public void run() {
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
}
System.out.println("线程的任务 = " + Thread.currentThread().getName());
}
}

?

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class ThreadPoolDemo {
public static void main(String[] args){
// 创建线程池容器并指定线程数量
ExecutorService tp = Executors.newFixedThreadPool(2);
// 提交Runnable任务
tp.submit(new RunnableTask());
tp.submit(new RunnableTask());
tp.submit(new RunnableTask());
// 立即销毁线程池，如果线程池中的任务还没有开始执行，就不会被执行。
tp.shutdownNow();
}
}

2.2 提交任务—Callable任务

/**

线程池提交任务：Callable任务

通过线程池工具类Executors的静态方法创建线程池对象

创建一个类实现Callable接口并重写call方法：线程任务相关的代码就写在该方法中

调用线程池对象的submit方法提交任务：Callable接口实现类对象

调用线程池对象的shutdown方法销毁线程池

Future接口常用方法

V get(); 获得Callable任务执行完毕后的返回值

Callable和Runnalbe任务的选择

如果任务执行完毕之后需要返回一个结果给调用者，则选择Callable任务

如果任务执行完毕没有返回值给调用者，则可以随便选择一个

*/

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
public class ThreadPoolDemo01 {
public static void main(String[] args) throws Exception {
// 创建线程池对象并指定线程数量
ExecutorService tp = Executors.newFixedThreadPool(2);
// 提交Callable任务
Future<String> f = tp.submit(new CallableTask());
System.out.println(f.get());
// 销毁线程池
tp.shutdown();
}
}

/**

自定义Callable接口实现类

*/

import java.util.concurrent.Callable;
public class CallableTask implements Callable<String> {
@Override
public String call() throws Exception {
System.out.println("线程的任务>>>>>>"+Thread.currentThread().getName());
return "ABC";
}
}