Java中线程调用Sleep时如何启动新线程继续执行任务

问题分析 #

你现有实现存在两个核心冗余问题：

1. FastestComparator的compare方法仅使用局部变量，无共享可变状态，完全不需要加synchronized锁，加锁反而强制所有线程串行执行，完全浪费多线程性能。
2. 循环调用interrupt()的逻辑属于无用忙等，会空占CPU资源。

推荐解决方案 #

使用JDK自带的线程池+invokeAny方法实现需求，不需要主动检测线程睡眠状态、也不需要手动中断线程：
invokeAny方法的特性是：提交一批任务后，只要任意一个任务执行成功返回，就会立刻返回该结果，同时自动取消其余未完成的所有任务，完美匹配你“找到匹配项就立刻返回”的需求。

实现步骤 #

1. 把单个实体的对比逻辑封装为独立的Callable任务：

public class CompareTask implements Callable<Integer> {
    private final int valueToFind;
    private final CustomNumberEntity entity;
    // FastestComparator无状态，可以共用也可以每个任务单独创建
    private final FastestComparator fastComparator = new FastestComparator();

    public CompareTask(int valueToFind, CustomNumberEntity entity) {
        this.valueToFind = valueToFind;
        this.entity = entity;
    }

    @Override
    public Integer call() {
        // 原有对比逻辑不需要修改，sleep逻辑不影响其他任务执行
        return fastComparator.compare(valueToFind, entity);
    }
}

2. 调用逻辑代码：

public boolean checkHasMatch(int valueToFind, List<CustomNumberEntity> list) {
    // 线程池大小可根据实际业务调整，这里设置为和CPU核心数一致
    ExecutorService executor = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors());
    List<Callable<Integer>> taskList = new ArrayList<>();
    for (CustomNumberEntity entity : list) {
        taskList.add(new CompareTask(valueToFind, entity));
    }

    try {
        // 最长等待60秒，可根据实际调整超时时间
        Integer result = executor.invokeAny(taskList, 60, TimeUnit.SECONDS);
        return result == 0;
    } catch (InterruptedException | ExecutionException | TimeoutException e) {
        // 所有任务都未返回0、或者超时的情况下返回false
        return false;
    } finally {
        // 关闭线程池，自动取消所有未完成的任务
        executor.shutdownNow();
    }
}

方案优势 #

• 线程池会自动调度线程资源，某个任务处于sleep状态时，空闲线程会直接处理其他等待的任务，不需要你手动检测线程状态开新线程。
• 不需要主动循环调用interrupt()，避免空占CPU资源。
• 自动处理多线程结果合并、任务取消的逻辑，不需要自己手动维护多线程状态。

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