Java并发编程中，线程池的创建与使用实例

原创骑猪看日落 2024-10-11 12:09 87阅读 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); // 提供5个线程

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

// 关闭线程池，所有提交的任务将被取消
        executor.shutdown();

// 确保所有任务已完成
        while (!executor.isTerminated())) {
            // 如果有未完成的任务，可以在这里进行一些处理
            Thread.sleep(1000); // 模拟操作
        }

// 线程池关闭后，所有提交的任务将被取消。
        System.out.println("All tasks completed.");
    }

static class Task implements Runnable {

private int index;

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

@Override
        public void run() {
            System.out.println("Task " + index + " started.");

try {
                Thread.sleep(2000); // 模拟操作
            } catch (InterruptedException e) {
                e.printStackTrace();
            }

System.out.println("Task " + index + " completed.");
        }
    }
}
```

在这个例子中，我们创建了一个固定大小的线程池，然后提交了10个任务到线程池。每个任务都在其自己的线程上运行。

当所有任务完成后，我们会关闭线程池并检查是否有未完成的任务。

还没有评论，来说两句吧...