c++: mutexを用いた排他処理につきまして

Question

質問内容

2つの異なるスレッドから下記コードの client_work(), get_client() をそれぞれ呼び出します.
排他処理を行い busy状態をチェックしているのでそれぞれのスレッドが同じタイミングにclientを扱うことはない
と考えたのですがどうも同じタイミングでclientを扱うことがあるようです。

mutexの扱いを間違っている箇所等ありますでしょうか？

mutex mtx;

// 1秒毎にclientのbusy状態をチェックしbusyでなければ、busyにしてからdo()を呼び出す.
void client_work() {
  thread th([] {
    unique_lock<mutex> lock(mtx, defer_lock); // 遅延ロック
    while (1) {
      mtx.lock();
      if (!client->busy) {
        client->busy = true;
        mtx.unlock();
        client->do(); // 重い処理を行う
        client->busy = false;
      } else {
         mtx.unlock();
      }
      sleep(1);
    }
  }
  th.detach(); // アプリが終わるまでずっと処理継続
}

// clientがbusyでなくなった時点でclientを返す. (呼び出し側はclientの処理が終わった時点で client->busy = false にする)
Client *get_client() {
  while(1) {
    lock_guard<mutex> lock(mtx);
     if(!client->busy) {
       client->busy = true;
       return client;
     }
  }  
}

本来、上のようなケースでは condition_variable などが有効だとは思うのですが
このコードは実際に利用しているコードを極力シンプルにしたものでしてwhileにより都度 busy状態の確認が必須となります。

どうぞ宜しくお願いいたします。

Comments

[yuki23]

このコードで問題の現象が発生するのですか？

[SHOMI]

CPUやコンパイラにより実行順序が変更されてclient->do();より先にclient->busy = false;が実行されているのかもしれません。

[guriguri]

yuki23さん　
実際のコードをシンプルにしたものですのでこれが動作していないわけではないのですが
実際のコードと排他制御の部分は全く一緒です。
SHOMIさん
え、そんなことが・・・？

[guriguri]

yuki23さん、SHOMIさん
本当に申し訳ないのですがシンプルにしたコードが間違っておりました・・・。
実際のコードではlockとunlockが一致しておりませんでした。

Answer 1

実際のコードが間違っておりました。
lockとunlockが一致しておりませんでした。
すみません。