Java中的并发工具类(如Future和ExecutorService)使用实例及问题

原创电玩女神 2024-11-30 09:03 17阅读 0赞

在Java中，`Future` 和 `ExecutorService` 是两种主要的并发工具。下面会通过几个实例来解释它们的使用以及可能遇到的问题。

1. **Future** 使用实例：
   - 定义一个异步任务（Runnable或Callable）：
   
   ```java
   // 创建一个Runnable对象，定义异步操作
   Runnable task = () -> {
       // 这里是异步操作的具体代码
       System.out.println("Task executed asynchronously");
       // 假设这里需要返回一个结果
       return "Result from asynchronous operation";
     };
   ```

- 创建`ExecutorService`并提交任务：

```java
   // 创建一个线程池，这里选择单线程模式
   ExecutorService executor = Executors.newSingleThreadExecutor();
   
   // 提交任务到线程池执行
   Future<String> futureTaskResult = executor.submit(task);
   
   // 等待异步任务完成并获取结果
   try {
       System.out.println("Waiting for task completion...");
       String resultFromTask = futureTaskResult.get(); // 获取任务结果
       
       System.out.println("Task completed with result: " + resultFromTask);
     } catch (InterruptedException | ExecutionException e) {
       System.err.println("Error occurred while waiting for task completion:");
       e.printStackTrace();
     }
   ```

2. **ExecutorService** 使用实例及问题：
   - 创建一个线程池，如上面的单线程模式：

```java
   ExecutorService executor = Executors.newSingleThreadExecutor();
   ```

- 提交任务到线程池执行：

```java
   // 同样提交任务到线程池执行
   futureTaskResult = executor.submit(task);
   ```

- 问题及解决：
     - **任务过多导致线程池满**：可以调整线程池大小，例如将单线程模式改为多线程模式：

```java
   // 创建一个包含一定数量线程的线程池
   ExecutorService executor = Executors.newFixedThreadPool(10); // 10个线程
   ```

- **任务执行时间过长**：可以采用异步处理方式，如使用`CompletableFuture`替换`Future`。

请根据实际场景选择合适的工具和方法。