这块代码注解说获取全局线程池，这里只是新建了一个线程池，是我理解错了吗？

稍微可以调整一下
```java
    //不配置拒绝策略，使用默认的拒绝策略
    ThreadPoolExecutor executor = new ThreadPoolExecutor(
            (int) Math.floor((threadsum() * 2) * 0.8), // 核心线程数: IO类型的任务通常建议设置为CPU核心数的两倍左右
            (int) Math.floor((threadsum() * 4) * 0.8), // 最大线程数：IO类型的任务建议设置为核心线程数的2-4倍
            60, // 空闲线程存活时间
            TimeUnit.SECONDS, // 时间单位
            new LinkedBlockingQueue<>(10000));

//这里创建全局线程池，同时尽可能的限制了CPU不能超过百分之八十（不能保证一定不超过百分之八十，CPU使用率取决于多个因素，包括任务的性质（计算密集型或IO密集型）、任务的执行时间、线程调度策略等。）
    // 因为弹性伸缩通常会配置cpu最大使用率不能超过百分之八十，超过就新增一台服务器，降低机器负载情况，所以这里可以限制一下，将核心线程数调低一点。
    // 另外短暂时间达到百分之百，弹性伸缩也不会立即新增服务器，它会监控机器某一段时间的负载情况，所以稍微控制一下即可。
    ThreadPoolExecutorUtil threadPoolExecutorUtil = new ThreadPoolExecutorUtil(
            (int) Math.floor((threadsum() * 2) * 0.8), // 核心线程数: IO类型的任务通常建议设置为CPU核心数的两倍左右
            (int) Math.floor((threadsum() * 4) * 0.8), // 最大线程数：IO类型的任务建议设置为核心线程数的2-4倍
            60, // 空闲线程存活时间
        TimeUnit.SECONDS, // 时间单位
            new LinkedBlockingQueue<>(10000), // 队列容量
            new RejectedExecutionHandler() {//自定义拒绝策略
        @Override
        public void rejectedExecution(Runnable r, java.util.concurrent.ThreadPoolExecutor executor) {
            log.info("自定义拒绝策略，使用滑动时间窗口和重试纪元");
            //滑动时间窗口：一段时间内有N条以内数据被拒绝可以进行重试，超过N条就发送告警，用这种形式避免雪上加霜的重试和没有必要的告警。
            // 举个例子：假设有100万条数据被拒绝了100条，可以直接执行重试机制，因为拒绝的占比非常小，如果100万条数据被拒绝了10万条数据甚至更多，说明线程池参数定义有问题或者有其他性能问题，这是不建议走重试机制，而是进行报警人工干预
            CustomTask task = (CustomTask)r;
            log.info("将被拒绝的任务发布消息到消息中间件(或者存入数据库)，然后等待订阅重试，此时重试纪元为" + task.getRetryEpoch());
            //发送MQ消息（）
            messageProducer.sendMessageInTransaction(ThreadPoolConstant.REJECTED_TASK, JSONObject.toJSONString(task));
            int windowSize = 300;//设置时间窗口大小为3
            long currentTimeMillis = System.currentTimeMillis();//当前时间戳
            //队列不为空且最早入队的元素超过指定时间窗口大小（单位为秒），则发送告警，进行人工干预并移除元素
            if (!queue.isEmpty() && currentTimeMillis - queue.peek() > windowSize * 1000) {
                //使用poll()方法从队列中检索并删除头部元素
                queue.poll();
            }
            //将新元素放到队列尾部
            queue.offer((int)System.currentTimeMillis());
        }
    }, this);

public ThreadPoolExecutor getThreadPoolExecutor(){
        return executor;
    }

public ThreadPoolExecutorUtil threadPoolExecutor() {
        return threadPoolExecutorUtil;
    }
```

java_wxid/高并发项目

内容风险标识

评论 (2)