线程池参数
- corePoolSize 核心线程数,
- 最大线程数 maximumPoolSize,
- 线程没有执行任务保持多久会终止 keepAliveTime,
- 时间单位 TimeUnit unit,
- 阻塞队列 BlockingQueue<Runnable> workQueue
所有的任务调度都是由execute方法完成。
线程池执行顺序
- 首先检测线程池运行状态,如果不是running,则直接拒绝。
- 如果workCount < corePoolSize,则创建并启动一个线程线程来执行提交任务。
- 如果workCount >= corePoolSize,且线程池阻塞队列未满,则将任务添加到阻塞队列中。
- 如果workCount >= corePoolSize && workCount < maximumPoolSize,并且线程池内的阻塞队列已满,则创建并启动一个线程来执行新提交的任务。
- 如果workCount >= maximumPoolSize ,并且阻塞队列已满,则根据拒绝策略来处理改任务,默认是直接抛出异常
package thread;
import org.junit.Test;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
/**
* @Author: jeremy
* @Date:
* @desc:
*/
public class ThreadPoolTest {
int corePoolSize = 3;
int maximumPoolSize = 5;
@Test
public void test() {
BlockingQueue<Runnable> workQueue = new LinkedBlockingQueue<>(5);
ThreadPoolExecutor executor =new ThreadPoolExecutor(corePoolSize,maximumPoolSize,1L, TimeUnit.MILLISECONDS,workQueue);
//执行任务,未达到核心线程数之前,创建线程
executor.execute(new TestTask());
executor.execute(new TestTask());
executor.execute(new TestTask());
//核心线程满了,阻塞队列未满,任务添加到队列中
executor.execute(new TestTask());
executor.execute(new TestTask());
executor.execute(new TestTask());
executor.execute(new TestTask());
executor.execute(new TestTask());
//阻塞队列满了,任务未达到最大线程数
executor.execute(new TestTask());
executor.execute(new TestTask());
//任务大于最大线程数,执行拒绝策略
executor.execute(new TestTask());
}
}
class TestTask implements Runnable{
@Override
public void run() {
try {
TimeUnit.DAYS.sleep(1);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
总结流程
核心线程数 → 添加到队列 →添加到最大线程数 → 达到最大线程数根据拒绝策略处理(抛异常或者忽略)
网友评论