一、 Java 创建线程池主要有以下三种方式
1. 默认线程池 ForkJoinPool
2. 通过调用执行器 Executors中的静态方法
3. 通过 ThreadPoolExector
import java.util.concurrent.*;
// 自定义线程工厂
class MyThreadFactory implements ThreadFactory {
@Override
//ThreadFactory 主要是对线程做一些定制: 比如说线程名字
public Thread newThread(Runnable r) {
// 创建线程池中的线程
Thread thread = new Thread(r);
// 设置线程名称
thread.setName("Thread-" + r.hashCode());
// 设置线程优先级(最大值:10)
thread.setPriority(Thread.MAX_PRIORITY);
return new Thread(thread );
}
}
public class ThreadPooling {
public static void main(String[] args) {
// 1. 系统自带线程池
ForkJoinPool forkJoinPool = new ForkJoinPool();
// 当前线程池中正在执行的线程继续执行完成,未执行的线程中断
forkJoinPool.shutdown();
// 当前执行的通过Thread.interrupt()进行中断, 未执行的立即返回
forkJoinPool.shutdownNow();
// 2. 不推荐使用这种方式创建线程池 --- 底层还是使用 ThreadPoolExecutor
ExecutorService executorService1 = Executors.newFixedThreadPool(5);
ExecutorService executorService2 = Executors.newCachedThreadPool();
executorService1.shutdown();
// 3.推荐使用的线程池创建方式
ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(
5,
10,
60,
TimeUnit.SECONDS,
new LinkedBlockingDeque<Runnable>(50),
new MyThreadFactory(),
new ThreadPoolExecutor.AbortPolicy());
}
}
二、ThreadPoolExecutor 中的参数值含义:
构造方法如图所示:
1.corePoolSize::核心线程数量(核心工作线程数量,当该线程全部工作后,还有任务到达,则将任务放进阻塞队列中)
2.maximumPoolSIze:最大工作线程数量(当阻塞队列满了之后,支持继续创建线程参与工作,但是线程池中全部的线程数量不能超过该数值)
3.keepAliveTime:存活时间 (当任务干完后,除了核心线程之外的线程存活的时间,超过存活时间则关闭)
4.TimeUnit:时间单位(参数3的单位,即多余线程的存活时间单位)
5.BlockingQueue<Runnable> workQueue:阻塞队列(线程池存放任务的队列)
6. ThreadFactory:线程工厂(定制线程,比如线程名字)
7. RejectedExecutionHandler:拒绝策略(当线程池的任务超出线程池队列可以存储的最大值之后,执行的策略)
- AbortPolicy:拒绝并抛出异常。
- CallerRunsPolicy:使用当前调用的线程来执行此任务。
- DiscardOldestPolicy:抛弃队列头部(最旧)的一个任务,并执行当前任务。
- DiscardPolicy:忽略并抛弃当前任务。