std::recursive_timed_mutex::try_lock_for

来自cppreference.com

 
 
并发支持库
线程
(C++11)
(C++20)
(C++20)
this_thread 命名空间
(C++11)
(C++11)
(C++11)
原子类型
(C++11)
(C++20)
原子类型的初始化
(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++20)
(C++20)
future
(C++11)
(C++11)
(C++11)
(C++11)
 
 
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 中的某个时间点此互斥量没有被任何其他线程锁定。

如果此操作返回 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; // 控制到 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 << "成功 ";
            std::this_thread::sleep_for(100ms);
            mutex.unlock();
        }
        else
            stream << "失败 ";
 
        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& i: threads)
        i.join();
}

可能的输出:

[0] 失败 失败 失败 
[3] 失败 失败 成功 
[2] 失败 成功 失败 
[1] 成功 失败 成功

缺陷报告

下列更改行为的缺陷报告追溯地应用于以前出版的 C++ 标准。

缺陷报告 应用于 出版时的行为 正确行为
LWG 2093 C++11 try_lock_for 不会抛出 抛出超时相关异常

参阅

锁定互斥,若互斥不可用则阻塞
(公开成员函数)
尝试锁定互斥,若互斥不可用则返回
(公开成员函数)
尝试锁定互斥,若直至抵达指定时间点互斥不可用则返回
(公开成员函数)
解锁互斥
(公开成员函数)