从并发角度看：Java线程池使用示例

原创淩亂°似流年 2024-10-23 14:24 57阅读 0赞

Java线程池是Java中一种管理和复用线程的机制。它可以帮助我们更好地控制并发，避免频繁创建和销毁线程。

以下是一个简单的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 = () -> {
                System.out.println("Task " + i + " started by thread: " + Thread.currentThread().getName());
                try {
                    Thread.sleep(500); // 模拟耗时操作
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("Task " + i + " finished by thread: " + Thread.currentThread().getName());
            };

executor.execute(task);
        }

// 关闭线程池，提交的任务会阻塞直到线程池关闭
        executor.shutdown();

// 确保所有任务已完成（线程池可能已经关闭）
        while (!executor.isTerminated()) {
            try {
                Thread.sleep(100); // 检查间隔
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

System.out.println("All tasks finished.");
    }
}
```

这段代码首先创建了一个固定大小的线程池，然后提交了10个任务到线程池。每个任务都是一个耗时操作的模拟。

最后，当所有任务完成后，程序会输出一条消息。