Java并发工具类比如ExecutorService的使用问题

原创柔光的暖阳◎ 2024-10-12 08:00 47阅读 0赞

在Java中，`ExecutorService`是`java.util.concurrent`包中的一个接口，用于管理线程池。它提供了一种异步执行任务的方式。

以下是一些关于`ExecutorService`使用的常见问题和解决方法：

1. **创建线程池**：
   ```java
   ExecutorService executor = Executors.newFixedThreadPool(5); // 创建固定大小的线程池
   ```

2. **提交任务到线程池**：
   ```java
   Future<Integer> future = executor.submit(() -> { // 任务逻辑 return 42; }); // 提交任务，返回一个Future对象

try {
       Integer result = future.get(); // 获取任务结果
       System.out.println(result); // 输出结果
     } catch (InterruptedException | ExecutionException e) {
       e.printStackTrace();
     }
   ```

3. **关闭线程池**：
   ```java
   executor.shutdown(); // 关闭线程池

try {
       while (!executor.isTerminated())) { // 等待所有任务完成或线程池被中断
           Thread.sleep(100); // 暂停一秒
       }
   } catch (InterruptedException e) {
       e.printStackTrace();
   }
   ```

4. **使用`shutdownNow()`**：
   ```java
   // 关闭并立即中断所有正在执行的线程
   executor.shutdownNow();

try {
       // 等待所有任务完成或线程池被中断
       while (!executor.isTerminated())) {
           Thread.sleep(100); // 暂停一秒
       }
   } catch (InterruptedException e) {
       e.printStackTrace();
   }
   ```

以上就是在Java中使用`ExecutorService`的基本操作。根据实际需求，可能还需要进行更复杂的任务管理。