std::recursive_timed_mutex::try_lock_for
来自 cppreference.cn
< cpp | thread | recursive timed mutex
| template< class Rep, class Period > bool try_lock_for( const std::chrono::duration<Rep, Period>& timeout_duration ); |
(自 C++11 起) | |
尝试锁定互斥量。阻塞直至指定的时长 timeout_duration 经过（超时）或获得锁（拥有互斥量），以先发生者为准。成功获得锁时返回 true，否则返回 false。
若 timeout_duration 小于或等于 timeout_duration.zero()，则此函数的行为如同 try_lock()。
由于调度或资源竞争延迟，此函数可能阻塞超过 timeout_duration。
标准建议使用 std::steady_clock 来测量时长。若实现改用 std::system_clock，则等待时间也可能对时钟调整敏感。
如同 try_lock()，即使在 timeout_duration 期间的某个时刻互斥量未被任何其他线程锁定，此函数也允许伪造失败并返回 false。
先前的对同一互斥量的 unlock() 操作与此操作同步 (synchronizes-with) （如 std::memory_order 中所定义），如果此操作返回 true。
线程可以重复地在递归互斥量上调用 try_lock_for。成功调用 try_lock_for 会增加所有权计数：互斥量仅在线程对 unlock() 进行匹配次数的调用后才会被释放。
所有权级别的最大数量是未指定的。如果超过此数量，则对 try_lock_for 的调用将返回 false。
内容 |
[编辑] 参数
| timeout_duration | - | 最小阻塞时长 |
[编辑] 返回值
true 若成功获得锁则为 true，否则为 false。
[编辑] 异常
timeout_duration 抛出的任何异常（标准库提供的时长永不抛出）。
[编辑] 示例
运行此代码
#include <chrono> #include <iostream> #include <mutex> #include <sstream> #include <thread> #include <vector> using namespace std::chrono_literals; std::mutex cout_mutex; // control access to std::cout std::timed_mutex mutex; void job(int id) { std::ostringstream stream; for (int i = 0; i < 3; ++i) { if (mutex.try_lock_for(100ms)) { stream << "success "; std::this_thread::sleep_for(100ms); mutex.unlock(); } else stream << "failed "; std::this_thread::sleep_for(100ms); } std::lock_guard<std::mutex> lock{cout_mutex}; std::cout << '[' << id << "] " << stream.str() << '\n'; } int main() { std::vector<std::thread> threads; for (int i{0}; i < 4; ++i) threads.emplace_back(job, i); for (auto& th : threads) th.join(); }
可能的输出
[0] failed failed failed [3] failed failed success [2] failed success failed [1] success failed success
缺陷报告
以下行为变更缺陷报告被追溯应用到先前发布的 C++ 标准。
| DR | 应用于 | 已发布行为 | 正确行为 |
|---|---|---|---|
| LWG 2093 | C++11 | try_lock_for 不抛出任何异常 |
抛出与超时相关的异常 |
[编辑] 参见
| 锁定互斥量，若互斥量不可用则阻塞 (public member function) | |
| 尝试锁定互斥量，若互斥量不可用则返回 (public member function) | |
| 尝试锁定互斥量，若互斥量已 不可用直至到达指定时间点则返回 (public member function) | |
| 解锁互斥量 (public member function) |
