命名空间
变体
操作

std::recursive_timed_mutex::try_lock_for

来自 cppreference.cn
 
 
并发支持库
线程
(C++11)
(C++20)
this_thread 命名空间
(C++11)
(C++11)
(C++11)
协同取消
互斥
(C++11)
通用锁管理
(C++11)
(C++11)
(C++11)
(C++11)
(C++11)
条件变量
(C++11)
信号量
门闩和屏障
(C++20)
(C++20)
期值
(C++11)
(C++11)
(C++11)
(C++11)
安全回收
(C++26)
危险指针
原子类型
(C++11)
(C++20)
原子类型的初始化
(C++11)(C++20 中已弃用)
(C++11)(C++20 中已弃用)
内存排序
(C++11)(C++26 中已弃用)
原子操作的自由函数
原子标志的自由函数
 
 
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() 一样,此函数可能虚假地失败并返回 false,即使在 timeout_duration 期间的某个时间点互斥体未被其他任何线程锁定。

同一互斥体上先前的 unlock() 操作与此操作同步(如 std::memory_order 中定义),如果此操作返回 true

一个线程可以重复调用递归互斥体上的 try_lock_for。成功调用 try_lock_for 会增加所有权计数:互斥体只有在线程进行了匹配次数的 unlock() 调用后才会被释放。

所有权的最大层数未指定。如果超出此数目,调用 try_lock_for 将返回 false

目录

[编辑] 参数

timeout_duration - 最少阻塞持续时间

[edit] 返回值

如果成功获取锁,则为 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++ 标准。

缺陷报告 应用于 发布时的行为 正确的行为
LWG 2093 C++11 try_lock_for 未抛出任何异常 抛出与超时相关的异常

[编辑] 参阅

锁定互斥体,如果互斥体不可用则阻塞
(public member function) [edit]
尝试锁定互斥体,如果互斥体不可用则返回
(public member function) [edit]
尝试锁定互斥锁,如果互斥锁在指定超时时间内不可用,则返回
在指定时间点之前不可用
(public member function) [edit]
解锁互斥体
(public member function) [edit]