Реализовать обработку сообщений с помощью мьютекса

mutex mt;
condition_variable cv;
 
string message; // буфер для сообщений
 
void deposit(int n) // поток производителей
{
        while (true)
        {
            for (int i = 0; i < n; ++i) // отправка сообщений производителями
            {
                {
                std::unique_lock <std::mutex>lk(mt);
                cv.wait(lk, [] {return message.empty();}); // ожидание прочтения нового сообщения всеми потребителями
                cout << "Manufacturer number " << i + 1 << ". Enter a message: ";
                getline(cin, message); // ввод сообщения
 
                message += ("/" + to_string(i + 1)); // отправка нового сообщения (добавляется номер производителя)
                }
                cv.notify_one(); // пробуждение потока потребителей для чтения очередного сообщения
                if (message.find("exit") != -1) // завершение потока при вводе "exit"
                    return;
            }
 
        }
 
}
 
void fetch(int m)
{
    while (true)
    {
        {
        std::unique_lock <std::mutex>lk(mt);
        cv.wait(lk, [] {return !message.empty();}); // ожидание сообщения
        if (message.find("exit") != -1) // завершение потока при вводе "exit"
            break;
        for (int i = 0; i < m; ++i) // все потребители выводят полученное сообщение
        {
            cout << message << endl;
        }
        message.clear(); // очистка буфера от сообщения
        cout << endl;
        }
        cv.notify_one(); // пробуждения потока производителей
    }
}
 
int main()
{
    int n = 3;
    int m = 5;
 
    thread t1(deposit, n);
    thread t2(fetch, m);
 
    t1.join();
    t2.join();
 
    system("pause");
    return 0;
}