Java中的并发编程，线程池的使用案例

原创一时失言乱红尘 2024-09-15 06:36 66阅读 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++) {
            final int index = i;
            executor.execute(() -> processTask(index)));
        }

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

// 检查线程池是否已经关闭，如果还没有，将抛出InterruptedException
        while (!executor.isTerminated()) {
            System.out.println("Still running tasks...");
            try {
                Thread.sleep(1000); // 等待一段时间
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

// 所有任务完成后，关闭线程池并释放资源
        executor.shutdownNow();

System.out.println("All tasks completed.");
    }

private static void processTask(int index) {
        try {
            Thread.sleep(500); // 模拟耗时操作
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("Task " + index + " processed.");

// 任务处理完成后，将此线程返回到线程池中
        executor.execute(() -> processTask(index + 1)));
    }
}
```

在这个例子中，我们创建了一个固定大小的线程池。然后提交了10个任务给线程池，每个任务都模拟了一种耗时操作。

在任务处理完成后，我们会将当前线程返回到线程池中，以便后续任务可以使用这些空闲的线程。