std::shared_timed_mutex:: try_lock_for

尝试锁定互斥量。阻塞直到指定的持续时间 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 ，则行为是未定义的。

参数

返回值

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 << "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

参见