线程池参数、线程池扩容以及拒绝策略触发时机demo代码

2020-08-04 19:00:15 阅读：315 来源： 互联网

标签：当前任务触发 demo ActiveCount 线程此时 id 10

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.RejectedExecutionHandler;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;

public class Tests {


    private static final AtomicInteger COUNTER = new AtomicInteger(1);

    private static final AtomicInteger THREAD_EXPAND = new AtomicInteger(1);
    
    // 阻塞队列一旦满了会抛出异常
    private static final LinkedBlockingQueue QUEUE = new LinkedBlockingQueue(30);

    public static void main(String[] args) {

        int corePoolSize = 4;
        int maximumPoolSize = 10;

        //  线程池第二个参数是线程组大数量
        //  只有在WORK QUEUE满了之后才会扩容
        //  如果WORK QUEUE满进行过扩容之后依旧有任务追加则会执行RejectedExecutionHandler策略
        ThreadPoolExecutor executor = new ThreadPoolExecutor(corePoolSize, maximumPoolSize, 1000L, TimeUnit.MILLISECONDS, QUEUE, new RejectedExecutionHandler() {
            @Override
            public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
                System.out.println("rejectedExecution $: 此处队列大小：" + QUEUE.size() + "    此时ActiveCount： " + executor.getActiveCount() + " 拒绝次数： " + COUNTER.getAndIncrement());

            }
        });

        for (int i = 1; i <= 50; i++) {
            executor.submit(new Runnable() {
                @Override
                public void run() {
                    try {
                        Thread.sleep(1000000);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            });

            System.out.println("当前任务id ：" + i + " => 此时ActiveCount：" + executor.getActiveCount());
            if (executor.getActiveCount() > corePoolSize && executor.getActiveCount() < maximumPoolSize) {
                System.out.println("线程池进行扩容：" + THREAD_EXPAND.getAndIncrement() + " 共计活跃线程数：" + executor.getActiveCount());
            }
        }
    }
}

// output：
//        当前任务id ：1 => 此时ActiveCount：1
//        当前任务id ：2 => 此时ActiveCount：2
//        当前任务id ：3 => 此时ActiveCount：3
//        当前任务id ：4 => 此时ActiveCount：4
//        当前任务id ：5 => 此时ActiveCount：4
//        当前任务id ：6 => 此时ActiveCount：4
//        当前任务id ：7 => 此时ActiveCount：4
//        当前任务id ：8 => 此时ActiveCount：4
//        当前任务id ：9 => 此时ActiveCount：4
//        当前任务id ：10 => 此时ActiveCount：4
//        当前任务id ：11 => 此时ActiveCount：4
//        当前任务id ：12 => 此时ActiveCount：4
//        当前任务id ：13 => 此时ActiveCount：4
//        当前任务id ：14 => 此时ActiveCount：4
//        当前任务id ：15 => 此时ActiveCount：4
//        当前任务id ：16 => 此时ActiveCount：4
//        当前任务id ：17 => 此时ActiveCount：4
//        当前任务id ：18 => 此时ActiveCount：4
//        当前任务id ：19 => 此时ActiveCount：4
//        当前任务id ：20 => 此时ActiveCount：4
//        当前任务id ：21 => 此时ActiveCount：4
//        当前任务id ：22 => 此时ActiveCount：4
//        当前任务id ：23 => 此时ActiveCount：4
//        当前任务id ：24 => 此时ActiveCount：4
//        当前任务id ：25 => 此时ActiveCount：4
//        当前任务id ：26 => 此时ActiveCount：4
//        当前任务id ：27 => 此时ActiveCount：4
//        当前任务id ：28 => 此时ActiveCount：4
//        当前任务id ：29 => 此时ActiveCount：4
//        当前任务id ：30 => 此时ActiveCount：4
//        当前任务id ：31 => 此时ActiveCount：4
//        当前任务id ：32 => 此时ActiveCount：4
//        当前任务id ：33 => 此时ActiveCount：4
//        当前任务id ：34 => 此时ActiveCount：4
//        当前任务id ：35 => 此时ActiveCount：5
//        线程池进行扩容：1 共计活跃线程数：5
//        当前任务id ：36 => 此时ActiveCount：6
//        线程池进行扩容：2 共计活跃线程数：6
//        当前任务id ：37 => 此时ActiveCount：7
//        线程池进行扩容：3 共计活跃线程数：7
//        当前任务id ：38 => 此时ActiveCount：8
//        线程池进行扩容：4 共计活跃线程数：8
//        当前任务id ：39 => 此时ActiveCount：9
//        线程池进行扩容：5 共计活跃线程数：9
//        当前任务id ：40 => 此时ActiveCount：10
//        rejectedExecution $: 此处队列大小：30    此时ActiveCount： 10 拒绝次数： 1
//        当前任务id ：41 => 此时ActiveCount：10
//        rejectedExecution $: 此处队列大小：30    此时ActiveCount： 10 拒绝次数： 2
//        当前任务id ：42 => 此时ActiveCount：10
//        rejectedExecution $: 此处队列大小：30    此时ActiveCount： 10 拒绝次数： 3
//        当前任务id ：43 => 此时ActiveCount：10
//        rejectedExecution $: 此处队列大小：30    此时ActiveCount： 10 拒绝次数： 4
//        当前任务id ：44 => 此时ActiveCount：10
//        rejectedExecution $: 此处队列大小：30    此时ActiveCount： 10 拒绝次数： 5
//        当前任务id ：45 => 此时ActiveCount：10
//        rejectedExecution $: 此处队列大小：30    此时ActiveCount： 10 拒绝次数： 6
//        当前任务id ：46 => 此时ActiveCount：10
//        rejectedExecution $: 此处队列大小：30    此时ActiveCount： 10 拒绝次数： 7
//        当前任务id ：47 => 此时ActiveCount：10
//        rejectedExecution $: 此处队列大小：30    此时ActiveCount： 10 拒绝次数： 8
//        当前任务id ：48 => 此时ActiveCount：10
//        rejectedExecution $: 此处队列大小：30    此时ActiveCount： 10 拒绝次数： 9
//        当前任务id ：49 => 此时ActiveCount：10
//        rejectedExecution $: 此处队列大小：30    此时ActiveCount： 10 拒绝次数： 10
//        当前任务id ：50 => 此时ActiveCount：10

标签：当前任务,触发,demo,ActiveCount,线程,此时,id,10
来源： https://www.cnblogs.com/leodaxin/p/13435195.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

线程池参数、线程池扩容以及拒绝策略触发时机demo代码