如何理解并实现Java中的线程池？请举例说明

原创朱雀 2025-03-13 10:15 6阅读 0赞

在Java中，线程池是一种资源管理机制，用于重复执行任务而无需每次都创建新的线程。这不仅可以提高系统的响应速度，还可以减少对系统资源的消耗。

以下是一个简单的线程池实现：

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

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

// 提交任务到线程池执行
        for (int i = 0; i < 10; i++) {
            Runnable task = new Task("Task " + i);
            executor.execute(task);
        }

// 关闭线程池，不再接受新的任务
        executor.shutdown();

// 等待所有任务完成或线程池关闭
        while (!executor.isTerminated()) {
            try {
                Thread.sleep(1000); // 每秒检查一次状态
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

// 所有任务都已经完成，线程池已经关闭
        System.out.println("All tasks completed, thread pool closed.");
    }

static class Task implements Runnable {
        private String taskName;

public Task(String taskName) {
            this.taskName = taskName;
        }

@Override
        public void run() {
            System.out.println("Task " + taskName + " started.");
            try {
                Thread.sleep(2000); // 模拟任务执行时间
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("Task " + taskName + " completed.");
        }
    }
}
```

在这个例子中，我们创建了一个固定大小的线程池（5个线程）。然后，我们提交了10个任务到线程池执行。每个任务都是一个简单的Runnable实现，包含了模拟任务执行的过程。

最后，我们关闭线程池，并等待所有任务完成或线程池关闭。在这个过程中，我们使用`executor.isTerminated()`来检查线程池的状态。