如何正确使用互斥锁？

Question

我有 mailBox 类，在线程和线程之间共享发送和接收方法：线程 1 发送消息，线程 2 和 3 接收消息，我必须如何使用互斥锁来同步它？

我尝试过的任何组合都没有成功。

std::mutex g_lock; //in global
void sendMessage(Message msg) {
    if (g_lock.try_lock()) {
        this_thread::sleep_for(100ms); // DELAY
        messages->push_back(msg);
        g_lock.unlock();
    }
}

Receive方法相同

完整代码：https : //pastebin.com/7y2RC5br

此代码也无法调试，因为延迟会更改代码的逻辑。

代码的正确逻辑：线程2/3尝试锁定并读取消息，获取空然后解锁线程1尝试锁定并发送消息然后解锁线程2/3尝试锁定并读取消息，获取消息并写入文件然后解锁

当我从线程 2/3 尝试互斥锁的 try_lock 时，我一直在不断阻塞线程，并且线程 1 在所有线程 2/3 之后一直在工作。

Answer 1

将低级互斥体包装成构建块类型。

基于锁的线程安全非常容易出错。它不仅易碎，而且不会组合；三个成对线程安全的例程在组合时可能是不安全的。

线程安全是一种关系属性，而不是绝对属性。

有各种已知的模式已被数学证明有效。正确实施，你就不会那么注定了。把一些东西放在一起，你的代码将不正确。

要设计新的线程代码，您需要擅长基于证明的计算机科学。实现比正确设计更容易。

在您的情况下，我将从线程安全队列原语开始。您将需要条件变量、互斥锁和 std deque。然后将每个例程连接到队列的一端，并将消息发送到另一端。（读取器应该只从队列中读取并按顺序使用每条消息；写入器只能在队列上发送消息）。

我的意思是，这仍然很难做到正确，但至少你的原语不是原始的互斥体。

template<class T>
struct threadsafe_queue {
  T pop();
  void push(T);
  std::deque<T> pop_all();

  std::optional<T> try_pop();
  template<class...Ts>
  std::optional<T> wait_for_pop( std::chrono::duration<Ts...> );
private:
  mutable std::mutex m;
  std::condition_variable cv;
  std::deque<T> queue;
  std::unique_lock<std::mutex> lock() const;
};