Java中的并发工具库：理解和实战示例

原创ゝ一世哀愁。 2024-10-16 04:48 50阅读 0赞

在Java中，为了处理并发和多线程问题，引入了Java的并发工具库。这个库包括了多种并发工具，如`ExecutorService`、`Callable`、`Future`等。

以下是一些常用的并发工具库实战示例：

1. 使用`ExecutorService`执行任务：
```java
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class ExecutorExample {
    public static void main(String[] args) {
        // 创建一个线程池，大小为5个线程
        ExecutorService executor = Executors.newFixedThreadPool(5);

// 提交任务到线程池，任务会立即执行（如果线程池中有空闲线程）
        for (int i = 0; i < 10; i++) {
            final int index = i;
            executor.submit(() -> "Task " + index + " executed"));
        }

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

// 确保所有任务已完成（如果线程池中有空闲线程，可能会延迟完成）
        while (!executor.isTerminated()) {
            try {
                Thread.sleep(100);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

System.out.println("All tasks completed!");

// 删除任务
        executor.shutdownNow();

}
}
```

2. 使用`Callable`和`Future`进行异步计算：
```java
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future;

public class CallableExample {
    public static void main(String[] args) {
        // 创建一个Callable任务，返回值为字符串"Task Result"
        Callable<String> callableTask = () -> "Task Result";

// 提交任务到ExecutorService执行
        Future<String> futureResult = executor.submit(callableTask);

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

private static ExecutorService executor = Executors.newFixedThreadPool(5);
}
```

通过以上示例，你可以更好地理解和使用Java的并发工具库。