Java中的并发编程：ExecutorService的使用示例

原创蔚落 2024-09-22 16:03 54阅读 0赞

在Java中，`ExecutorService`是一个接口，它是Java并发包中的一部分。它提供了一种对线程进行管理的方式。

以下是如何使用`ExecutorService`的一个示例：

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

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

// 提交10个任务到线程池中执行
        for (int i = 0; i < 10; i++) {
            Runnable task = () -> {
                System.out.println("Task " + i + " is running");
                try {
                    Thread.sleep(2000); // 模拟耗时操作
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("Task " + i + " finished.");
            };
            executor.execute(task);
        }

// 关闭线程池，防止资源泄露
        executor.shutdown();

// 等待所有任务完成，如果还有未完成的任务，则会抛出异常
        while (!executor.isTerminated()) {
            System.out.println("Still running tasks...");
            try {
                Thread.sleep(1000); // 模拟程序暂停
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

// 所有任务都已完成，可以安全地关闭线程池
        System.out.println("All tasks finished. Executor pool closed.");
    }
}
```

这个示例中，我们创建了一个固定大小的线程池（10个线程），然后提交了10个任务到线程池中执行。每个任务都是一个简单的 Runnable 对象，它模拟了一段耗时的操作。最后，我们关闭了线程池，确保资源的安全。