如何用executor.execute与future.get()非阻塞主线程实现任务超时中断并解决线程翻倍问题

原代码线程数量翻倍的核心原因是：你提交到executor的每个任务，都会额外创建一个独立线程执行Goring的业务逻辑，executor分配的线程仅用于执行future.get()的超时等待逻辑，两类线程各占总线程数的一半，最终总线程数是预期的2倍，属于完全不必要的资源浪费。

优化核心逻辑是复用executor的线程执行业务任务，用轻量的单调度线程统一处理所有任务的超时检查，既满足不阻塞主线程、超时中断任务的要求，也不会产生冗余线程。
优化要点：

• 直接将业务逻辑作为任务提交到executor，拿到对应的Future对象，不需要额外创建独立线程跑业务
• 新增单线程调度池来异步执行超时检查逻辑，不会阻塞主线程
• 超时后调用future.cancel(true)触发线程中断，终止超时任务

如果你要求必须使用future.get()实现超时判断，可使用如下实现：

// 初始化业务线程池（线程数按业务需求调整）、超时检查调度池
ExecutorService executor = Executors.newFixedThreadPool(10);
ScheduledExecutorService timeoutChecker = Executors.newSingleThreadScheduledExecutor();

for (int i : array) {
    // 直接提交业务任务到executor，复用executor线程执行
    Future<?> future = executor.submit(() -> {
        Goring goring = new Goring();
        goring.goring(i);
    });

    // 提交延迟检查任务到调度池，不阻塞主线程
    timeoutChecker.schedule(() -> {
        try {
            // 超时时间和你原代码保持一致，可按需调整
            future.get(1, TimeUnit.NANOSECONDS);
        } catch (InterruptedException | ExecutionException | TimeoutException e) {
            e.printStackTrace();
            // 触发中断终止超时任务
            future.cancel(true);
        }
    }, 1, TimeUnit.NANOSECONDS);
}

// 执行完后关闭线程池资源
executor.shutdown();
timeoutChecker.shutdown();

• 线程数符合预期：仅包含业务线程池配置的N个线程 + 1个调度线程，无冗余线程
• 主线程全程不阻塞：所有超时检查逻辑都在调度线程异步执行
• 完全满足你的需求：支持超时触发中断终止任务，使用future.get()做超时判断，没有阻塞主线程

内容的提问来源于stack exchange，提问作者ChadRasputin