关于线程池的问题

V2EX = way to explore

V2EX 是一个关于分享和探索的地方

现在注册

已注册用户请登录

• 请不要在回答技术问题时复制粘贴 AI 生成的内容

这是一个创建于 900 天前的主题，其中的信息可能已经有所发展或是发生改变。

线程池有个疑问，我的机器 4 核 16G,按照最优的线程数 2n+1 来说为 9 个，但是在如下代码中

public static void main(String[] args) {
        // 创建线程池，500 个线程数
        ExecutorService es = ThreadUtils.getInstance("approveProcessForBatch", 500);
        Map<Integer, Future<Object>> futureMap = new HashMap<>(SystemConstant.INITIAL_CAPACITY);
        for (int i = 0; i <= 250; i++) {
            // delay5s 耗时 5s
            es.submit(() -> delay5s(""));
        }
        System.out.println("开始执行时间：" + DateTime.now());
        for (int i = 0; i <= 100; i++) {
            int finalI = i;
            Future<Object> future = es.submit(() -> delay5s("当前任务" + finalI));
            futureMap.put(finalI, future);
        }
        futureMap.keySet().forEach(i -> {
            try {
                // v 是当前任务名称
                Object v = futureMap.get(i).get();
                System.out.println(v + "，完成时间：" + DateTime.now());
            } catch (ExecutionException | InterruptedException e) {
                throw new BusinessException(e);
            }
        });
    }

目前设置了 500 个线程数，会在 5s 之后将 100 个任务全部完成，假如我只设置 9 个，那预计需要 250/9 * 5s 的时间，导致这个现象的原因是啥？

int

线程池

线程数

future

13 条回复 • 2023-05-17 18:12:06 +08:00

blankmiss

2023-05-15 15:41:30 +08:00

什么原因你倒是说清楚啊

mango88

2023-05-15 16:02:57 +08:00

从你的描述看，ThreadUtils.getInstance 代码仅是设置了 corePoolSize
不清楚你的这段代码是如何设置线程池其他几个参数的，maximumPoolSize ，workQueue 等
如果是无界队列的话，队列满了才会去创建新的线程（线程数 > corePoolSize ）直到线程数 = maximumPoolSize