多线程实践：如何在Java中实现一个线程池？

原创叁歲伎倆 2024-09-11 09:42 14阅读 0赞

在Java中，我们可以使用`ExecutorService`和`ThreadPoolExecutor`类来创建和管理线程池。

以下是一个简单的例子，展示了如何创建一个固定大小的线程池：

```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++) {
            Runnable task = () -> {
                System.out.println("Task " + i + " is running by thread " + Thread.currentThread().getId());
                try {
                    Thread.sleep(500);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            };
            executor.execute(task);
        }

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

// 检查线程池是否已关闭且所有任务已完成（没有正在运行的线程）
        while (!executor.isTerminated()) {
            System.out.println("仍有线程在执行..."));
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

// 确保所有任务已完成
        while (executor.getTaskCount() != 0) {
            System.out.println("仍有未完成的任务...");
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

// 打印所有已提交但尚未完成的任务
        for (Runnable task : executor.getTasksForRunning()) {
            System.out.println("Task " + task + " is running but not completed yet...");
        }

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

这个例子创建了一个固定大小（5个）的线程池，并提交了10个任务到线程池。每个任务都会打印一条消息，表示其正在被线程执行。

最后，我们关闭线程池以释放资源。