理解Java并发工具线程池：阻塞与非阻塞问题实例

原创﹏ヽ暗。殇╰゛Y 2024-10-10 07:57 61阅读 0赞

在Java编程中，线程池是一个重要的并发工具，它能够高效地管理和重复利用线程。

1. 阻塞与非阻塞问题：
   - 阻塞型（Blocking）：当线程提交任务到线程池后，会一直等待任务完成或者超时。例如，`ExecutorService.submit(runnable)`，如果runnable是一个耗时操作，那么submit方法将阻塞。

- 非阻塞型（Non-blocking）：线程在等待任务完成时，不会被阻塞，而是继续执行其他任务。这种方式通常用于高并发场景下的异步处理。

2. 实例：
假设我们有一个简单的HTTP服务，每个请求都会生成一个随机数并返回。在这种情况下，我们可以使用阻塞型线程池来实现。

```java
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

public class BlockingThreadPoolExample {
    private static final int THREAD_POOL_SIZE = 10; // 10个线程

public static void main(String[] args) throws InterruptedException {
        // 创建线程池
        ExecutorService executorService = Executors.newFixedThreadPool(THREAD_POOL_SIZE));

// 提交任务到线程池，阻塞等待任务完成
        for (int i = 0; i < 100; i++) { // 每个请求生成一个随机数
            int randomNum = (int) Math.random();
            executorService.submit(() -> {
                System.out.println("Task " + i + ": " + randomNum);
            }));
        }

// 关闭线程池，所有提交的任务将全部完成并清理资源
        executorService.shutdown();
        executorService.awaitTermination(1, TimeUnit.MINUTES)); // 确保所有任务在指定时间内完成
    }
}
```

这个例子展示了如何使用阻塞型线程池来实现多请求并发服务。