Java阻塞Q测试停止执行

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

public class BlockingQueueTest {
    private static volatile boolean stopExecution = false;

    public static void main(String[] args) {
        BlockingQueue<String> queue = new LinkedBlockingQueue<>();

        // 生产者线程
        Thread producerThread = new Thread(() -> {
            try {
                while (!stopExecution) {
                    // 添加任务到队列
                    queue.put("Task");
                    System.out.println("Added task to queue");
                    Thread.sleep(1000);
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        });

        // 消费者线程
        Thread consumerThread = new Thread(() -> {
            try {
                while (!stopExecution) {
                    // 从队列中取出任务并执行
                    String task = queue.take();
                    System.out.println("Executing task: " + task);
                    Thread.sleep(2000);
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        });

        // 启动生产者和消费者线程
        producerThread.start();
        consumerThread.start();

        // 模拟条件满足时停止执行
        try {
            Thread.sleep(5000);
            stopExecution = true;
            System.out.println("Stopping execution");
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}