Java中的并发工具类如ExecutorService、Callable等的理解与实践示例

原创深碍√TFBOYSˉ_ 2024-10-16 21:03 137阅读 0赞

在Java中，`ExecutorService`，`Callable`等是用于管理和处理多线程任务的重要工具。

1. ExecutorService：它是Java的`java.util.concurrent`包中的一个接口。`ExecutorService`主要用于管理一组工作者（Worker）来执行任务。例如，你可以创建一个服务，它接受任务并让线程去完成。

2. Callable：这是一个继承自`FutureTask`的接口，主要区别在于返回值类型。当线程执行完 Callable 接口中的方法后，返回的结果会存储在 `Future` 对象中，可以通过 `get()` 方法获取。

实践示例：

```java
import java.util.concurrent.*;

public class ExecutorServiceExample {
    // 创建一个固定大小的线程池
    private static ExecutorService executor = Executors.newFixedThreadPool(10);

public static void main(String[] args) {
        // 提交任务到线程池执行
        Future<String> future = executor.submit(new Task());

try {
            // 等待任务完成并获取结果
            String result = future.get();
            System.out.println("Task completed. Result: " + result);
        } catch (InterruptedException | ExecutionException e) {
            e.printStackTrace();
        }
    }

static class Task implements Callable<String> {
        @Override
        public String call() {
            try {
                Thread.sleep(2000); // 模拟耗时操作
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            return "Task completed successfully!";
        }
    }
}
```

这个示例创建了一个固定大小的线程池，然后提交了一个实现了`Callable<String>`接口的任务到线程池执行。最后通过`Future.get()`方法获取到了任务完成的结果。