Java并发编程实战：基于ExecutorService的示例

原创淡淡的烟草味﹌ 2024-09-26 18:42 42阅读 0赞

在Java中，`ExecutorService`是Java Concurrency API（C++）的一部分。它提供了一种异步的方式来管理线程。

以下是一些基于`ExecutorService`的示例：

1. **提交任务到线程池**：
```java
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class ThreadPoolExample {
    public static void main(String[] args) {
        ExecutorService executor = Executors.newFixedThreadPool(5); // 创建固定大小线程池

// 提交任务到线程池
        for (int i = 0; i < 10; i++) {
            Runnable worker = () -> System.out.println("Task " + i + " executed by thread " + Thread.currentThread().getName()); // 定义任务
            executor.execute(worker); // 提交任务
        }

// 关闭线程池，提交的任务将不再执行新的任务
        executor.shutdown();
    }
}
```

2. **使用`Future`**：
在Java 8及更高版本中，你可以使用`Future`来获取异步操作的结果。

```java
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class FutureExample {
    public static void main(String[] args) {
        ExecutorService executor = Executors.newFixedThreadPool(5); // 创建固定大小线程池

// 提交任务到线程池，获取`Future`
        List<Future<String>> futures = new ArrayList<>();
        for (int i = 0; i < 10; i++) {
            futures.add(executor.submit(() -> "Task " + i)))));
        }

// 检查并打印所有任务的结果
        for (Future<String> future : futures) {
            try {
                System.out.println("Task " + future.get().split("-")[0]) + " executed.");
            } catch (Exception e) {
                System.err.println("Error while getting result: " + e.getMessage());
            }
        }

// 关闭线程池
        executor.shutdown();
    }
}
```

这些示例展示了如何在Java中使用`ExecutorService`进行并发编程。