ExecutorCompletionService仅单线程运行，任务无执行返回null问题排查

核心问题1：结果处理循环逻辑严重错误，导致任务未被完整执行 #

你的parallelMatch方法中的结果收集循环存在致命逻辑缺陷：

• 当service.poll(10L, TimeUnit.SECONDS)返回null时，代码执行finished++后直接break退出循环，剩余未处理的任务会被直接放弃，根本不会等待其执行完成
• 无论poll是否成功获取到结果，finally块都会执行finished++，这会导致循环在极短时间内结束（仅循环几次就满足finished >= len），大量任务还未被线程池调度执行，就被判定为"完成"

核心问题2：线程池实际配置可能不符合预期 #

你声明线程池为Executors.newFixedThreadPool(Math.max(this.cpu, THREADS))，但如果this.cpu的实际值为1（或小于可用处理器数量），线程池会被初始化为单线程池，这就会导致所有任务都在同一个线程中串行执行，和日志中仅出现单个线程的现象完全吻合。

其他潜在问题 #

• MatchCaller的call方法目前仅返回空的MatchCallerResult，如果实际业务逻辑中存在阻塞或未正确实现，也可能导致任务执行异常
• 异常捕获块catch (Exception e)为空，无法排查任务执行过程中出现的异常，可能导致任务失败但无任何日志提示

修复方案 #

1. 修正结果收集循环逻辑 #

将poll改为take（阻塞等待任务完成），或修复poll的循环逻辑，确保等待所有任务执行完成：

while (finished < len) {
  Future<MatchCallerResult> future = null;
  try {
    // 使用take()阻塞等待任务完成，替代poll避免提前退出
    future = service.take();
    MatchCallerResult mr = future.get();
    allResults[mr.order] = mr;
  } catch (InterruptedException e) {
    Thread.currentThread().interrupt();
    logger.error("任务处理被中断", e);
    break;
  } catch (Exception e) {
    logger.error("任务执行失败", e);
  } finally {
    finished++;
  }
}

如果必须使用poll，调整逻辑避免提前退出：

while (finished < len) {
  Future<MatchCallerResult> future = null;
  try {
    future = service.poll(10L, TimeUnit.SECONDS);
    if (future != null) {
      MatchCallerResult mr = future.get();
      allResults[mr.order] = mr;
      finished++;
    } else {
      logger.warn("等待任务完成超时，继续等待剩余任务");
    }
  } catch (Exception e) {
    logger.error("任务处理异常", e);
    finished++;
  }
}

2. 确保线程池配置符合预期 #

检查this.cpu的实际值，确保线程池初始化时使用正确的线程数：

// 显式指定16线程，或确保this.cpu的值正确
int poolSize = 16;
logger.info("初始化线程池，核心线程数：{}", poolSize);
public ExecutorService executor = Executors.newFixedThreadPool(poolSize);

3. 完善异常处理与任务逻辑 #

• 在catch块中添加日志，排查任务执行异常
• 确保MatchCaller的call方法正确实现业务逻辑，避免无意义的空返回

内容的提问来源于stack exchange，提问作者World of Titans