线程池执行顺序

2021-05-19  本文已影响0人  小码A梦

线程池参数

所有的任务调度都是由execute方法完成。

线程池执行顺序

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();
        }
    }
}

总结流程

核心线程数 → 添加到队列 →添加到最大线程数 → 达到最大线程数根据拒绝策略处理(抛异常或者忽略)

测试代码

上一篇下一篇

猜你喜欢

热点阅读