Java并发编程：线程池的创建与使用示例

原创末蓝、 2024-11-23 18:36 30阅读 0赞

线程池是Java中一种常用的多线程资源管理模式。它能够重用已有的线程，避免频繁地创建和销毁线程。

以下是一个简单的线程池创建与使用的示例：

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

public class ThreadPoolExample {

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

// 提交任务到线程池，任务会由线程池中的空闲线程执行
        for (int i = 0; i < 10; i++) {
            executor.submit(new Task(i)));
        }

// 关闭线程池，所有提交的任务都会等待当前任务完成后再执行
        executor.shutdown();

try {
            // 确保线程池已经完全关闭，不会再有新的任务被添加
            if (!executor.isTerminated()) {
                System.out.println("Error: Executor is not terminated.");
            }

// 检查所有任务是否都已经完成
            for (Task task : executor.invokeAll(new ArrayList<Task>())) {
                System.out.println("Task completed: " + task.getTaskId());
            }
        } catch (InterruptedException | ExecutionException e) {
            System.out.println("Error occurred while executing tasks: " + e.getMessage());
            e.printStackTrace();
        } finally {
            // 确保清理线程池，释放资源
            executor.shutdownNow();
        }
    }

static class Task implements Runnable {

private int taskId;

public Task(int taskId) {
            this.taskId = taskId;
        }

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

public int getTaskId() {
            return taskId;
        }
    }
}
```

这个示例中，我们创建了一个固定大小的线程池（5个线程），然后提交了10个任务给线程池。每个任务都会模拟执行一段时间，最后任务完成时会打印出任务ID。当所有任务完成后，我们会关闭线程池并清理资源。