并发编程实践：Java线程池的用法示例

原创缺乏、安全感 2024-10-16 11:30 26阅读 0赞

在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);  // 设置最大线程数为5

// 提交任务到线程池执行
        for (int i = 0; i < 10; i++) { 
            Runnable task = () -> {
                System.out.println("Task " + i + " is running by thread: " + Thread.currentThread().getName());
                try {
                    Thread.sleep(500);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            };
            executor.execute(task);  // 提交任务到线程池执行
        }

// 关闭线程池，释放资源
        executor.shutdown();  // 让线程池等待所有任务完成或者超时后关闭
        while (!executor.isTerminated())) {   // 确保所有线程已经退出
            System.out.println("仍有线程未退出，等待...");
            try {
                Thread.sleep(1000);  // 等待一段时间，如果还有未退出的线程，程序将陷入无限循环
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

// 所有任务完成或超时后关闭线程池
        System.out.println("所有任务已执行完毕。线程池已关闭。");

}
}
```

上述示例中，我们创建了一个固定大小的线程池（5个线程），然后提交了10个任务到线程池进行并发执行。

每个任务都是一个Runnable子类，它包含要执行的任务逻辑。在提交任务后，我们确保所有线程都退出，最后关闭线程池。