- mutex[meta header]
- std[meta namespace]
- class[meta id-type]
- cpp11[meta cpp]
namespace std {
class recursive_timed_mutex;
}
recursive_timed_mutex
は、スレッド間で使用する共有リソースを排他制御するためのクラスであり、再帰的なロックと、ロック取得のタイムアウト機能をサポートする。lock()
メンバ関数によってリソースのロックを取得し、unlock()
メンバ関数でリソースのロックを手放す。
このクラスのデストラクタは自動的にunlock()
メンバ関数を呼び出すことはないため、通常このクラスのメンバ関数は直接は呼び出さず、lock_guard
やunique_lock
といったロック管理クラスと併用する。
名前 | 説明 | 対応バージョン |
---|---|---|
(constructor) |
コンストラクタ | C++11 |
(destructor) |
デストラクタ | C++11 |
operator=(const recursive_timed_mutex&) = delete |
代入演算子 | C++11 |
lock |
ロックを取得する | C++11 |
try_lock |
ロックの取得を試みる | C++11 |
try_lock_for |
タイムアウトする相対時間を指定してロックの取得を試みる | C++11 |
try_lock_until |
タイムアウトする絶対時間を指定してロックの取得を試みる | C++11 |
unlock |
ロックを手放す | C++11 |
native_handle |
ミューテックスのハンドルを取得する | C++11 |
名前 | 説明 | 対応バージョン |
---|---|---|
native_handle_type |
実装依存のハンドル型 | C++11 |
#include <iostream>
#include <mutex>
#include <thread>
#include <chrono>
#include <system_error>
class counter {
int count_ = 0;
std::recursive_timed_mutex mtx_;
public:
int add(int value)
{
// ロックを取得する(3秒でタイムアウト)
if (!mtx_.try_lock_for(std::chrono::seconds(3))) {
// ロック取得がタイムアウト
std::error_code ec(static_cast<int>(std::errc::device_or_resource_busy), std::generic_category());
throw std::system_error(ec);
}
int result = count_ += value;
mtx_.unlock();
return result;
}
int increment()
{
// ロックを取得する(3秒でタイムアウト)
if (!mtx_.try_lock_for(std::chrono::seconds(3))) {
// ロック取得がタイムアウト
std::error_code ec(static_cast<int>(std::errc::device_or_resource_busy), std::generic_category());
throw std::system_error(ec);
}
int result = add(1); // add()関数内でも同じミューテックスからロックを取得する
mtx_.unlock();
return result;
}
};
std::mutex print_mtx_;
void print_value(int value)
{
std::lock_guard<std::mutex> lock(print_mtx_);
std::cout << "count == " << value << std::endl;
}
counter c;
void change_count()
{
int value = c.increment();
print_value(value);
}
int main()
{
std::thread t1(change_count);
std::thread t2(change_count);
t1.join();
t2.join();
}
- std::recursive_timed_mutex[color ff0000]
- mtx_.try_lock_for[link recursive_timed_mutex/try_lock_for.md]
- std::errc::device_or_resource_busy[link /reference/system_error/errc.md]
- std::generic_category()[link /reference/system_error/generic_category.md]
- std::system_error[link /reference/system_error/system_error.md]
- mtx_.unlock()[link recursive_timed_mutex/unlock.md]
count == 1
count == 2
- C++11
- Clang: ??
- GCC: 4.7.0 [mark verified]
- ICC: ??
- Visual C++: 2012 [mark verified], 2013 [mark verified], 2015 [mark verified]
- 2012, 2013は、(2)での実引数の受け渡しにムーブを使用しない問題がある。上記の例でも、
std::unique_ptr<int>
の実引数でコンパイルエラーになる。
- 2012, 2013は、(2)での実引数の受け渡しにムーブを使用しない問題がある。上記の例でも、