- 正确答案：生产者消费者模型是一种经典的多线程同步问题，用于描述多个生产者线程向缓冲区写入数据、多个消费者线程从缓冲区读取数据的场景。该模型的核心是通过线程间协作保证线程安全，避免缓冲区溢出或空读，并实现高效的资源利用。通常使用互斥锁（mutex）和条件变量（condition variable）来实现。 - 解答思路： 1. 明确模型的角色：生产者、消费者、共享缓冲区（通常为固定大小的队列）。 2. 理解并发问题：多个线程访问共享资源时可能出现竞争条件，必须使用同步机制保护。 3. 使用互斥锁防止多个线程同时操作缓冲区。 4. 使用两个条件变量分别表示“缓冲区非满”和“缓冲区非空”，以便在适当时候阻塞或唤醒线程。 5. 生产者在缓冲区满时等待，否则添加数据并通知消费者；消费者在缓冲区空时等待，否则取出数据并通知生产者。 6. 编码实现时注意加锁范围、条件判断使用while而非if（防止虚假唤醒），以及正确释放锁。 - 深度知识讲解：生产者消费者模型考察的是操作系统中的进程/线程同步、临界区管理、条件变量机制等底层知识点。其核心在于理解**线程安全**与**等待通知机制**。关键点包括： 1. **互斥锁（Mutex）**：确保同一时间只有一个线程可以访问缓冲区，防止数据竞争。 2. **条件变量（Condition Variable）**：允许线程在某个条件不满足时挂起（wait），并在其他线程改变状态后被唤醒（signal/broadcast）。它必须与互斥锁配合使用。 3. **虚假唤醒（Spurious Wakeup）**：即使没有被显式唤醒，线程也可能从wait中返回，因此必须用while循环检查条件是否真正成立。 4. **缓冲区设计**：常用环形队列（循环数组）或标准库中的线程安全队列（如C++的std::queue + 锁封装）。 5. **信号量替代方案**：也可用计数信号量（Semaphore）实现，empty_count表示空位数量，full_count表示已占用位置数量，初始分别为buffer_size和0。扩展应用场景： - 消息队列系统（如Kafka消费者组） - Web服务器的任务处理线程池 - 日志异步写入 - GUI事件循环与后台任务解耦底层原理涉及操作系统的调度、上下文切换、原子操作、内存可见性等问题。在Java中可使用BlockingQueue直接实现；在C/C++中常结合pthread或std::thread实现。 - 代码示例（C++风格伪代码，带注释）： ``` #include #include #include #include #include class ProducerConsumer { private: std::queue buffer; std::mutex mtx; std::condition_variable not_full; std::condition_variable not_empty; int capacity; public: ProducerConsumer(int cap) : capacity(cap) {} void producer(int item) { std::unique_lock lock(mtx); // 使用while防止虚假唤醒 while (buffer.size() == capacity) { std::cout << "Buffer is full, producer waits.\n"; not_full.wait(lock); // 释放锁并等待 } // 此时buffer不满，可以插入 buffer.push(item); std::cout << "Produced: " << item << ", buffer size: " << buffer.size() << "\n"; // 通知一个等待的消费者（可能有多个条件变量等待者） not_empty.notify_one(); // lock自动释放 } void consumer(int& item) { std::unique_lock lock(mtx); // 使用while防止虚假唤醒 while (buffer.empty()) { std::cout << "Buffer is empty, consumer waits.\n"; not_empty.wait(lock); } // 此时buffer非空，可以取出 item = buffer.front(); buffer.pop(); std::cout << "Consumed: " << item << ", buffer size: " << buffer.size() << "\n"; // 通知一个等待的生产者 not_full.notify_one(); } }; // 测试函数 void test_producer_consumer() { ProducerConsumer pc(5); // 容量为5的缓冲区 std::thread p1([&pc]() { for (int i = 1; i <= 10; ++i) { pc.producer(i); std::this_thread::sleep_for(std::chrono::milliseconds(100)); // 模拟生产耗时 } }); std::thread c1([&pc]() { for (int i = 0; i < 10; ++i) { int item; pc.consumer(item); std::this_thread::sleep_for(std::chrono::milliseconds(150)); // 消费较慢 } }); p1.join(); c1.join(); } ``` 说明： - unique_lock支持灵活的锁定控制，适合与condition_variable配合。 - notify_one()唤醒一个等待线程，若允许多个消费者/生产者可用notify_all()。 - sleep_for用于模拟生产和消费的速度差异，体现同步效果。 - 实际工程中可进一步扩展为线程池+任务队列模式。补充：若使用信号量实现（类Unix系统sem_t或C++20的counting_semaphore），代码更简洁： ``` std::counting_semaphore<0> empty(5); // 初始5个空位 std::counting_semaphore<0> full(0); // 初始0个满位 std::mutex mtx; void producer() { for (int i = 0; i < 10; ++i) { empty.acquire(); // 获取一个空位 std::lock_guard lock(mtx); buffer.push(i); std::cout << "Produced: " << i << "\n"; lock.unlock(); full.release(); // 增加一个满位 } } void consumer() { for (int i = 0; i < 10; ++i) { full.acquire(); // 获取一个满位 std::lock_guard lock(mtx); int item = buffer.front(); buffer.pop(); std::cout << "Consumed: " << item << "\n"; lock.unlock(); empty.release(); // 归还一个空位 } } ``` 总结：手撕生产者消费者模型不仅要求写出正确代码，更要理解其背后的并发控制思想——通过同步原语协调多线程对共享资源的访问，是构建高并发系统的基础能力。

百度搜索架构日常实习 go

全站热榜

创作者周榜