Java并发编程中的线程池应用实例

原创太过爱你忘了你带给我的痛 2024-09-10 19:24 69阅读 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++) {
            final int finalIndex = i;
            executor.submit(() -> {
                System.out.println("Task " + finalIndex + " is running by thread: " + Thread.currentThread().getName());
                try {
                    // 模拟耗时操作
                    Thread.sleep(500);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("Task " + finalIndex + " completed.");
            });
        }

// 关闭线程池，释放资源
        executor.shutdown();
        while (!executor.isTerminated())) {
            // 等待所有任务完成
            try {
                Thread.sleep(100);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

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

在这个例子中，我们创建了一个固定大小的线程池（5个线程）。然后提交了10个任务到线程池。每个任务模拟了一段耗时操作。最后关闭线程池以释放资源。