第1步：自定义线程实现类

Java中多线程编码时，定义线程类有两种方式：

• 继承Thread类
• 实现Runnable接口（由于Java的单继承特性，一般推荐使用此方式）

public class BizThread implements Runnable {private int idx;public BizThread(int idx) {this.idx = idx;}@Overridepublic void run() {long threadId = Thread.currentThread().getId();System.out.println("这是第" + idx + "个线程>>>>>>>>>【线程ID-" + threadId + "】业务逻辑begin");// region 模拟业务逻辑处理过程try {Thread.sleep(5000);} catch (InterruptedException e) {e.printStackTrace();}// endregionSystem.out.println("这是第" + idx + "个线程<<<<<<<<<【线程ID-" + threadId + "】业务逻辑end");}
}

第2步：使用ThreadPoolExecutor线程池启动线程

当调用线程池execute()方法添加一个任务时，线程池会做如下判断： ·

• 如果有空闲线程，则直接执行该任务； ·
• 如果没有空闲线程，且当前运行的线程数少于corePoolSize，则创建新的线程执行该任务； ·
• 如果没有空闲线程，且当前的线程数等于corePoolSize，同时阻塞队列未满，则将任务入队列，而不添加新的线程； ·
• 如果没有空闲线程，且阻塞队列已满，同时池中的线程数小于maximumPoolSize ，则创建新的线程执行任务； ·
• 如果没有空闲线程，且阻塞队列已满，同时池中的线程数等于maximumPoolSize，则根据构造函数中的handler指定的策略来拒绝新的任务。

public class MultiThreadTest {public static void main(String[] args) {// 定义线程池ExecutorService pool = new ThreadPoolExecutor(2,9,60,TimeUnit.SECONDS,new SynchronousQueue<>(),Executors.defaultThreadFactory(),new ThreadPoolExecutor.AbortPolicy());// 模拟10个线程并发for (int i=1; i<=10; i++) {pool.execute(new BizThread(i));}}
}

运行结果：

这是第1个线程>>>>>>>>>【线程ID-12】业务逻辑begin
这是第5个线程>>>>>>>>>【线程ID-16】业务逻辑begin
这是第3个线程>>>>>>>>>【线程ID-14】业务逻辑begin
这是第8个线程>>>>>>>>>【线程ID-19】业务逻辑begin
这是第4个线程>>>>>>>>>【线程ID-15】业务逻辑begin
这是第2个线程>>>>>>>>>【线程ID-13】业务逻辑begin
这是第7个线程>>>>>>>>>【线程ID-18】业务逻辑begin
这是第9个线程>>>>>>>>>【线程ID-20】业务逻辑begin
这是第6个线程>>>>>>>>>【线程ID-17】业务逻辑begin
Exception in thread "main" java.util.concurrent.RejectedExecutionException: Task com.etoak.BizThread@14ae5a5 rejected from java.util.concurrent.ThreadPoolExecutor@7f31245a[Running, pool size = 9, active threads = 9, queued tasks = 0, completed tasks = 0]at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2063)at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:830)at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1379)at com.etoak.MultiThreadTest.main(MultiThreadTest.java:50)
这是第8个线程<<<<<<<<<【线程ID-19】业务逻辑end
这是第6个线程<<<<<<<<<【线程ID-17】业务逻辑end
这是第5个线程<<<<<<<<<【线程ID-16】业务逻辑end
这是第1个线程<<<<<<<<<【线程ID-12】业务逻辑end
这是第2个线程<<<<<<<<<【线程ID-13】业务逻辑end
这是第7个线程<<<<<<<<<【线程ID-18】业务逻辑end
这是第3个线程<<<<<<<<<【线程ID-14】业务逻辑end
这是第9个线程<<<<<<<<<【线程ID-20】业务逻辑end
这是第4个线程<<<<<<<<<【线程ID-15】业务逻辑end

ThreadPoolExecutor构造方法参数说明：

1. corePoolSize（核心线程数量）：核心线程默认会一直存活，即使没有任务需要执行
2. maximumPoolSize（线程池最大线程数量）：线程池中能拥有最大线程数
3. keepAliveTime（空闲线程的存活时间）：当线程空闲时间达到keepAliveTime时，线程会销毁，线程数量默认会收缩至corePoolSize的大小
4. unit（时间单位）：指定keepAliveTime的单位
5. workQueue（任务队列）：缓存任务的排队策略（SynchronousQueue队列，一个不缓存任务的阻塞队列，本身没有容量大小；每个插入操作必须等到另一个线程调用移除操作，否则插入操作一直处于阻塞状态）
6. threadFactory（创建线程工厂）：默认会使用ThreadPoolExecutor.defaultThreadFactory()创建线程
7. handler（任务拒绝策略）：当workQueue已满，且线程池中的线程数达到maximumPoolSize时，线程池拒绝添加新任务时采取的策略（AbortPolicy策略：丢弃新任务，并抛出运行时异常由开发人员进行处理）