如何在消费者线程遇到异常时停止生产者线程

// 定义共享的标志变量
private volatile boolean stopProducing = false;

// 消费者线程
Thread consumerThread = new Thread(() -> {
    try {
        while (true) {
            // 消费者逻辑
            // ...
        }
    } catch (Exception e) {
        // 异常处理
        // ...
        // 设置标志变量为true
        stopProducing = true;
    }
});

// 生产者线程
Thread producerThread = new Thread(() -> {
    try {
        while (true) {
            // 生产者逻辑
            // ...
            
            // 检查标志变量的状态
            if (stopProducing) {
                // 停止生产
                break;
            }
        }
    } catch (Exception e) {
        // 异常处理
        // ...
    }
});

// 启动线程
consumerThread.start();
producerThread.start();