Java 在没有线程暂停的情况下执行 ExecutorService 中的任务

编辑:我刚刚发布了这个答案，并意识到您似乎在使用该代码模拟真实用户与某个系统的交互.我强烈建议只使用一个负载测试实用程序，而不是try 自己的.然而，在这种情况下，只使用CachedThreadPool就可以做到这一点，尽管这可能不是一个非常健壮或可伸缩的解决方案.

线这里的sleep()行为按预期工作:它挂起线程，让CPU执行其他线程.

因此，您需要两件相互排斥的事情:一方面，如果文档还没有准备好，线程应该可以自由地执行其他操作，但应该以某种方式返回并在10秒内再次判断文档的状态.

这意味着您必须 Select :

• 您肯定需要对每个文档进行每10秒一次的判断—在这种情况下，可以使用cachedThreadPool并让它生成所需的尽可能多的线程，但请记住，您将承担大量线程的开销，而这些线程实际上什么都不做.

• 或者，您可以首先启动异步文档创建过程，然后只判断可调用项中的状态，并根据需要重试.

类似于:

public class Task implements Callable<Boolean> {
    private final ReportClient client;
    private final UUID uuid;
    // all args constructor omitted for brevity
    @Override
    public Boolean call() {
        GetStatusResponse status = client.getStatus(uuid);
        if (Status.PENDING.equals(status.status())) {
            final var document = client.getReport(uuid);
            return Boolean.TRUE;
        } else {
            return Boolean.FALSE; //retry next time
        }
    }
}

List<Callable<Boolean>> callableTasks = new ArrayList<>();
for (int i = 0; i < 100; i++) { 
    var uuid = client.createDocument(documentId); //not sure where documentId comes from here in your code
    callableTasks.add(new Task(client, uuid));
}

List<Future<Boolean>> results = SERVICE.invokeAll(callableTasks); 
// retry logic until all results come back as `true` here

这假设createDocument是相对有效的，但该阶段也可以并行化，您只需要使用Runnable个任务的单独列表，并使用executor服务调用它们.