java中的阻塞队列应用场景及代码实例

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
class Producer implements Runnable {
    private BlockingQueue<String> taskQueue;
    public Producer(BlockingQueue<String> taskQueue) {
        this.taskQueue = taskQueue;
    }
    @Override
    public void run() {
        try {
            while (true) {
                String task = produceTask();
                taskQueue.put(task); // 将任务放入队列
                System.out.println("Produced task: " + task);
                Thread.sleep(1000); // 模拟生产任务的耗时
            }
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    }
    private String produceTask() {
        // 生成任务的逻辑
        return "Task";
    }
}
class Consumer implements Runnable {
    private BlockingQueue<String> taskQueue;
    public Consumer(BlockingQueue<String> taskQueue) {
        this.taskQueue = taskQueue;
    }
    @Override
    public void run() {
        try {
            while (true) {
                String task = taskQueue.take(); // 从队列中获取任务（如果队列为空，则阻塞等待）
                System.out.println("Consumed task: " + task);
                executeTask(task); // 执行任务的逻辑
            }
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    }
    private void executeTask(String task) {
        // 执行任务的逻辑
        System.out.println("Executing task: " + task);
    }
}
public class BlockingQueueExample {
    public static void main(String[] args) {
        BlockingQueue<String> taskQueue = new LinkedBlockingQueue<>(10); // 创建一个容量为10的阻塞队列
        // 创建生产者线程和消费者线程
        Thread producerThread = new Thread(new Producer(taskQueue));
        Thread consumerThread = new Thread(new Consumer(taskQueue));
        // 启动线程
        producerThread.start();
        consumerThread.start();
    }
}