Java并发编程：线程池和阻塞队列的实战案例

原创我不是女神ヾ 2024-09-15 21:42 94阅读 0赞

在Java并发编程中，线程池和阻塞队列是两个重要的工具。下面我将给出这两个概念的实战案例。

1. 线程池实战：

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

public class ThreadPoolExample {
    public static void main(String[] args) {
        // 创建线程池，核心线程数2，最大线程数5
        ExecutorService executor = Executors.newFixedThreadPool(5);

// 提交任务到线程池，这些任务会被并发执行
        for (int i = 0; i < 10; i++) {
            executor.submit(() -> "Task " + i));
        }

// 关闭线程池，不再接受新的提交任务
        executor.shutdown();

try {
            // 等待所有任务完成或者线程池关闭
            if (!executor.isTerminated()) {
                System.out.println("Executor is not terminated after shutdown, this may indicate an issue.");
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

}
}
```

2. 阻塞队列实战：

```java
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;

public class BlockQueueExample {
    public static void main(String[] args) {
        // 创建一个容量为10的阻塞队列
        BlockingQueue<Integer> queue = new LinkedBlockingQueue<>(10);

// 向队列中添加元素，如果队列已满，则会进入阻塞状态
        for (int i = 0; i < 15; i++) {
            try {
                queue.put(i); // 元素被添加到队列中
                System.out.println("Element " + i + " added to the queue successfully.");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

// 向队列中获取元素，如果队列为空，则会进入阻塞状态
        for (int i = 15; i < 20; i++) {
            try {
                Integer element = queue.take(); // 元素被从队列中移除并返回
                System.out.println("Element " + i + " retrieved from the queue successfully. Value: " + element);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

}
}
```

这两个实战案例分别展示了线程池和阻塞队列在Java并发编程中的应用。