java 中的阻塞队列用于实现生产者消费者模型：生产者线程向队列中添加数据，消费者线程从队列中读取数据。队列满时，生产者阻塞直到有空间可用；队列空时，消费者阻塞直到有数据可读。实战案例：缓存系统、消息队列、流水线处理等并发问题。
在 Java 中使用阻塞队列实现生产者消费者模型
阻塞队列是一种线程安全的数据结构，它可以帮助我们在生产者和消费者之间实现同步。生产者线程将数据添加到队列中，而消费者线程从队列中读取数据。如果队列已满，生产者会阻塞直到有空间可用。如果队列为空，消费者会阻塞直到有数据可供读取。
示例代码：
立即学习“Java免费学习笔记（深入）”；
Producer.java
import java.util.concurrent.BlockingQueue;
public class Producer implements Runnable {
private BlockingQueue queue;
public Producer(BlockingQueue queue) {
this.queue = queue;
}
@Override
public void run() {
for (int i = 0; i < 10; i++) {
try {
queue.put(i);
System.out.println("Produced: " + i);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
} Consumer.java
import java.util.concurrent.BlockingQueue;
public class Consumer implements Runnable {
private BlockingQueue queue;
public Consumer(BlockingQueue queue) {
this.queue = queue;
}
@Override
public void run() {
while (true) {
try {
Integer item = queue.take();
System.out.println("Consumed: " + item);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
} Main.java
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class Main {
public static void main(String[] args) {
BlockingQueue queue = new ArrayBlockingQueue<>(10);
Producer producer = new Producer(queue);
Consumer consumer = new Consumer(queue);
ExecutorService executorService = Executors.newFixedThreadPool(2);
executorService.submit(producer);
executorService.submit(consumer);
executorService.shutdown();
}
} 实战案例：
此模型可用于解决多种并发问题，例如：
- 在缓存系统中，生产者线程生成数据，而消费者线程使用数据。
- 在消息队列系统中，生产者线程发布消息，而消费者线程处理消息。
- 在流水线处理中，生产者线程生成中间数据，而消费者线程处理中间数据并生成最终结果。
