std::shared_timed_mutex::try_lock_for
来自 cppreference.com
< cpp | thread | shared timed mutex
template< class Rep, class Period > bool try_lock_for( const std::chrono::duration<Rep, Period>& timeout_duration ); |
(自 C++14 起) | |
尝试锁定互斥锁。阻塞直到指定的持续时间 timeout_duration 过去(超时)或获得锁(拥有互斥锁),以先发生者为准。如果成功获得锁,则返回 true,否则返回 false。
如果 timeout_duration 小于或等于 timeout_duration.zero(),则该函数的行为类似于 try_lock()。
由于调度或资源争用延迟,此函数可能阻塞的时间比 timeout_duration 更长。
标准建议使用 std::steady_clock 来测量持续时间。如果实现改为使用 std::system_clock,则等待时间也可能对时钟调整敏感。
与 try_lock() 一样,此函数允许虚假失败并返回 false,即使互斥锁在 timeout_duration 期间的某个时间点没有被任何其他线程锁定。
先前对同一互斥锁的 unlock() 操作同步于(如 std::memory_order 中所定义)此操作,如果它返回 true。
如果 try_lock_for
被一个已经以任何模式(共享或独占)拥有互斥锁的线程调用,则行为未定义。
内容 |
[编辑] 参数
timeout_duration | - | 阻塞的最小持续时间 |
[编辑] 返回值
如果成功获得锁,则为 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
[编辑] 另请参阅
锁定互斥锁,如果互斥锁不可用则阻塞 (公有成员函数) | |
尝试锁定互斥锁,如果互斥锁不可用则返回 (公有成员函数) | |
尝试锁定互斥锁,如果互斥锁一直不可用直到指定的时点才返回 未在指定时间点之前返回 (公有成员函数) | |
解锁互斥锁 (公有成员函数) |