Java并发工具-ExecutorService的正确使用-实例分析

原创亦凉 2024-11-01 23:39 7阅读 0赞

`ExecutorService` 是 Java并发包 `java.util.concurrent` 中的一个接口，它提供了一种管理线程池的方法。正确使用 `ExecutorService`可以有效地管理并发任务，提高程序性能和资源利用率。以下是一些关于如何正确使用 `ExecutorService` 的实例分析：

###1. 创建 ExecutorService创建 `ExecutorService` 的最常见方式是使用 `Executors` 类的工厂方法。例如：

```javaExecutorService executor = Executors.newFixedThreadPool(10); // 创建一个固定大小的线程池```###2. 提交任务使用 `ExecutorService` 提交任务，可以通过 `execute(Runnable command)` 方法提交不需要返回值的任务，或者通过 `submit(Callable<T> task)` 方法提交需要返回值的任务。

```javaexecutor.execute(new Runnable() {
 public void run() {
//任务代码 }
});

Future<String> future = executor.submit(new Callable<String>() {
 public String call() throws Exception {
//任务代码 return "result";
 }
});
```###3.处理结果对于通过 `submit` 方法提交的任务，可以通过 `Future` 对象获取结果。

```javaString result = future.get(); //阻塞直到任务完成并返回结果```###4. 关闭 ExecutorService当不再需要 `ExecutorService`时，应该调用 `shutdown()` 方法来关闭它。这个方法会等待正在执行的任务完成，然后关闭线程池。

```javaexecutor.shutdown();
```如果需要立即停止，可以使用 `shutdownNow()` 方法，它会尝试立即停止所有正在执行的任务，并返回等待执行的任务列表。

```javaList<Runnable> notExecutedTasks = executor.shutdownNow();
```###5.等待任务完成有时候，你可能需要等待所有任务都完成。这可以通过 `awaitTermination` 方法实现。

```javatry {
if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
 executor.shutdownNow(); // 超时后尝试立即停止 }
} catch (InterruptedException ex) {
 executor.shutdownNow();
Thread.currentThread().interrupt();
}
```###6.正确处理异常当使用 `submit` 方法提交任务时，如果任务执行过程中抛出异常，这个异常会被封装在 `Future` 的 `get` 方法中抛出的 `ExecutionException` 中。

```javatry {
String result = future.get();
} catch (InterruptedException e) {
//线程被中断} catch (ExecutionException e) {
//任务执行过程中抛出的异常}
```### 实例分析假设我们有一个任务，需要从多个 URL 下载数据，我们可以使用 `ExecutorService`来并发执行这些任务：

```javaExecutorService executor = Executors.newFixedThreadPool(10);

List<Future<String>> results = new ArrayList<>();

for (String url : urls) {
 Future<String> result = executor.submit(() -> downloadData(url));
 results.add(result);
}

for (Future<String> future : results) {
 try {
String data = future.get();
//处理下载的数据} catch (InterruptedException | ExecutionException e) {
//处理异常 }
}

executor.shutdown();
```在这个例子中，我们创建了一个固定大小的线程池，然后为每个 URL 提交了一个下载任务。我们收集了所有 `Future` 对象，并在所有任务提交后，遍历这些 `Future` 对象来获取结果。最后，我们关闭了线程池。

正确使用 `ExecutorService`需要理解线程池的工作原理，合理配置线程池大小，以及妥善管理任务的提交和结果处理。