std::shared_timed_mutex::try_lock_for

来自cppreference.com

 
C++
 
并发支持库
线程
(C++11)
(C++20)
(C++20)
(C++20)
(C++20)
(C++17)(C++17)
this_thread 命名空间
(C++11)
(C++11)
(C++11)
(C++11)
原子类型
(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++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)
内存序
(C++11)
(C++11)
(C++11)
(C++11)
互斥
(C++11)
(C++11)
(C++17)
通用锁管理
(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++11)
信号量
(C++20)(C++20)
闩与屏障
(C++20)
(C++20)
future
(C++11)
(C++11)
(C++11)
(C++11)
(C++11)
(C++11)
(C++11)
(C++11)
(C++11)
(C++11)
 
std::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 中的某个时间点此互斥量没有被任何其他线程锁定。

如果此操作返回 true，那么相同互斥量上先前的 unlock() 操作同步于（在 std::memory_order 定义）它。

如果已经以任何模式（共享或排他性）占有此互斥量的线程调用 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; // 控制到 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] 成功 失败 成功

参阅

 锁定互斥，若互斥不可用则阻塞
(公开成员函数)
尝试锁定互斥，若互斥不可用则返回
(公开成员函数)
尝试锁定互斥，若直至抵达指定时间点互斥不可用则返回
(公开成员函数)
解锁互斥
(公开成员函数)
来自“https://zh.cppreference.com/mwiki/index.php?title=cpp/thread/shared_timed_mutex/try_lock_for&oldid=45568”