为什么我的Executor服务每次都接近完成时都会卡住？

Question

简而言之，我有一个List userIds，它的大小可以从10k到100k，这些都是user_ids的，我的核心逻辑是，对于每user_id，我调用两个不同的rest api终端并获取这些有效负载，然后在有效负载之间进行验证操作

我通过以下方式使用executor服务来加快处理速度，我将记录拆分为批处理和预定义的100个线程，以便1个线程可以处理（int）（userIds.size（）/100）个用户

public void execute(List < String > userIds) {
    int numberOfThreads = 100;
    int WINDOW = (int) Math.floor(userIds.size() / numberOfThreads);
   
    int st = 0;
    int end = WINDOW;
   
    for (; st < userIds.size();) {
        int realStart = st;
        int realEnd = end;

        executor.execute(
            () - > {
                verify(realStart, realEnd, userIds) // this method has logic to verify users for the given start and end indexes from the userIds list

            }
        )
    
    st = end + 1;
    if (end + WINDOW >= userIds.size()) {
        end = userIds.size() - 1;
    } else {
        end = st + WINDOW;
    } // code to update the indexes realStart and realEnd for next 'n' batches
}
executor.shutDown();
try {
    System.out.println("Done");
    executor.awaitTermination(Long.MAX_VALUE, TimeUnit.SECONDS);
    System.out.println("Done on a rope");
} catch (Exception e) {
    e.printStackTrace();
}
}

比方说，对于10k记录，当它接近完成时，代码被卡住了，这让我想，如果ExecutorService中有几个线程被卡住了，如果是，我该如何解决它，或者我在这里是否有任何明显的缺陷？感谢您的帮助：）

Answer 1

假设有100个线程，一切都正常，您的系统可以处理它。

然后问题可以在方法中。比如说，你有10000个用户-

1. 验证（）方法的逻辑无法处理它
2. 用户ID的在列表userIds中不是唯一的，并且多个线程正在尝试同时处理相同的userId，并且可能会被与该用户ID相关的一些资源锁定。
3. 线程相互阻塞的其他问题，但同样-这取决于您的应用程序逻辑

注意：executor.await终止（Long.MAX_VALUE， TimeUnit. SECONDS）；只告诉执行器是否完成了它的处理，它不会在时间过去后强制它终止。根据Oracle的说法，正确的完成方式是：

executor.shutdown();
try {
    if (!executor.awaitTermination(800, TimeUnit.MILLISECONDS)) {
        executor.shutdownNow();
    } 
} catch (InterruptedException e) {
    executor.shutdownNow();
}

另一个注意事项：您可以使用而（st