static/chunks/766-12dbb05e2adf85ab.js","4150","static/chunks/app/courses/%5BcourseSlug%5D/lessons/%5BunitSlug%5D/page-1fc213a0f4568bd8.js"],"Image"] 3b:T6c9, int main() { ProducerConsumer pc(5); // Buffer capacity set to 5 std::mutex console_mutex; // Producer threads std::thread producer1([&pc, &console_mutex]() { for (int i = 0; i < 10; ++i) { pc.produce(i); { std::lock_guard lock(console_mutex); std::cout << "Produced: " << i << std::endl; } std::this_thread::sleep_for(std::chrono::milliseconds(100)); } }); std::thread producer2([&pc, &console_mutex]() { for (int i = 10; i < 20; ++i) { pc.produce(i); { std::lock_guard lock(console_mutex); std::cout << "Produced: " << i << std::endl; } std::this_thread::sleep_for(std::chrono::milliseconds(100)); } }); // Consumer threads std::thread consumer1([&pc, &console_mutex]() { for (int i = 0; i < 10; ++i) { int item = pc.consume(); { std::lock_guard lock(console_mutex); std::cout << "Consumed: " << item << std::endl; } std::this_thread::sleep_for(std::chrono::milliseconds(150)); } }); std::thread consumer2([&pc, &console_mutex]() { for (int i = 0; i < 10; ++i) { int item = pc.consume(); { std::lock_guard lock(console_mutex); std::cout << "Consumed: " << item << std::endl; } std::this_thread::sleep_for(std::chrono::milliseconds(150)); } }); producer1.join(); producer2.join(); consumer1.join(); consumer2.join(); return 0; }