如何判断线程池所有线程执行完成

在线程池中判断所有线程是否执行完毕通常有两种方法：

1. **Future集合**：如果你使用的是`ExecutorService`并提交了`Runnable`或`Callable`任务，可以使用`Future`接口的`get()`方法。这个方法会阻塞，直到对应的线程执行完成并且结果可用。你可以将所有Future放入List中，然后遍历这个列表，当所有的`get()`都返回或抛出异常时，表示所有任务已完成。

   List<Future<?>> futures = executor.invokeAll(tasks);
   for (Future<?> future : futures) {
       try {
           future.get(); // 如果抛出InterruptedException或ExecutionException，则线程未完成
       } catch (InterruptedException | ExecutionException e) {
           // 处理异常，如日志记录或取消剩余任务
       }
   }

2. **CountDownLatch**：如果任务的数量是已知的，可以创建一个`CountDownLatch`计数器，每个任务完成后调用其`countDown()`方法，主线程持有`CountDownLatch`实例并在所有任务完成后释放它。

   CountDownLatch latch = new CountDownLatch(poolSize);
   for (Runnable task : tasks) {
       pool.execute(() -> {
           try {
               task.run();
           } finally {
               latch.countDown(); // 线程结束时减少计数器
           }
       });
   }
   latch.await(); // 主线程阻塞等待所有任务完成

3. **Semaphore**：如果你需要更复杂的同步策略，比如允许某个资源在一定时间内被访问多次，可以使用`Semaphore`。当所有任务完成时，信号量的许可证数量会恢复到最大值。

无论哪种方法，都需要确保正确的异常处理和线程安全，以及考虑到异常情况下的清理工作。在实际应用中，结合业务需求和线程池的具体实现选择合适的方法。