Java中的并发编程：线程池示例

原创 Dear 丶 2024-10-05 18:03 80阅读 0赞

在Java中，线程池是一种常用的管理线程的方式。它能够重复使用已创建的线程，避免了频繁创建和销毁线程的开销。

以下是一个简单的线程池示例，使用了`java.util.concurrent.Executors`来创建一个固定大小的线程池：

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

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

// 提交任务到线程池
        for (int i = 0; i < 10; i++) {
            final int index = i;
            executor.execute(() -> {
                System.out.println("Task " + index + " is running...");
                // 模拟耗时操作
                try {
                    Thread.sleep(500); // 暂停500毫秒
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("Task " + index + " finished successfully...");
            });
        }

// 关闭线程池，所有提交的任务都将被阻塞，直到线程池关闭
        executor.shutdown();

// 检查线程池是否已经关闭
        while (!executor.isTerminated()) {
            System.out.println("Executor is still running...");
            try {
                Thread.sleep(1000); // 暂停1秒，让输出更明显
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

System.out.println("\nExecutor service has been successfully shutdown.");
    }
}
```

这个示例中，我们创建了一个固定大小的线程池（5个线程），然后提交了10个任务到线程池。每个任务都是一个模拟耗时操作的匿名内部类实例。

最后，我们关闭了线程池，并检查了所有提交的任务是否已经被阻塞等待线程池关闭。