命名空间
变体
操作

std::recursive_timed_mutex::try_lock_for

来自 cppreference.com

[编辑模板]
 
C++
 
并发支持库
线程
(C++11)
(C++20)
(C++17)(C++17)
this_thread 命名空间
(C++11)
(C++11)
(C++11)
(C++11)
协作式取消
互斥
通用锁管理
(C++11)
(C++11)
(C++17)
(C++11)
(C++14)
(C++11)
(C++11)
(C++11)
(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++20)
(C++20)
期货
(C++11)
(C++11)
(C++11)
(C++11)
(C++11)
(C++11)
(C++11)
(C++11)
(C++11)
(C++11)
安全回收
(C++26)
(C++26)
(C++26)
危险指针
(C++26)
(C++26)
(C++26)
原子类型
(C++11)
(C++20)
(C++11)
原子类型的初始化
(C++11)(C++20 中已弃用)
(C++11)(C++20 中已弃用)
(C++11)
内存排序
(C++11)
(C++11)
(C++11)
(C++11)
原子操作的自由函数
(C++11)(C++11)
(C++11)(C++11)
(C++11)(C++11)
(C++11)(C++11)(C++11)(C++11)
(C++11)(C++11)
(C++11)(C++11)
(C++11)(C++11)
(C++11)(C++11)
(C++11)(C++11)
(C++26)(C++26)
(C++26)(C++26)
(C++11)
(C++20)(C++20)
(C++20)
(C++20)
原子标志的自由函数
(C++11)(C++11)
(C++11)(C++11)
(C++20)(C++20)
(C++20)(C++20)
(C++20)
(C++20)
 
std::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。

如果返回 true，则对同一互斥锁的先前 unlock() 操作与（根据 std::memory_order 定义）此操作同步。

线程可以对递归互斥锁重复调用 try_lock_for。成功调用 try_lock_for 会增加所有权计数：只有在线程对 unlock() 进行相同次数的匹配调用后，才会释放互斥锁。

所有权级别的最大数量未指定。如果超过此数量，则调用 try_lock_for 将返回 false。

内容

[编辑] 参数

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

缺陷报告

以下行为更改缺陷报告已追溯应用到先前发布的 C++ 标准。

DR 应用于 已发布的行为 正确行为
LWG 2093 C++11 try_lock_for 未引发任何内容 引发与超时相关的异常

[编辑] 另请参阅

 锁定互斥锁，如果互斥锁不可用，则阻塞
(公共成员函数) [编辑]
 尝试锁定互斥锁，如果互斥锁不可用，则返回
(公共成员函数) [编辑]
 尝试锁定互斥锁，如果互斥锁在
指定时间点到达之前一直不可用，则返回
(公共成员函数) [编辑]
 解锁互斥锁
(公共成员函数) [编辑]
检索自 "https://cppreference.cn/mwiki/index.php?title=cpp/thread/recursive_timed_mutex/try_lock_for&oldid=124201"