命名空间
变体
操作

std::shared_mutex::lock_shared

来自 cppreference.com
< cpp‎ | thread‎ | shared mutex
 
 
并发支持库
线程
(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 中已弃用)
内存排序
原子操作的自由函数
原子标志的自由函数
 
 
void lock_shared();
(自 C++17 起)

获取互斥锁的共享所有权。如果另一个线程以独占所有权持有互斥锁,则调用 lock_shared 将阻塞执行,直到可以获取共享所有权。

如果 lock_shared 被已经以任何模式(独占或共享)拥有 mutex 的线程调用,则行为未定义。

如果以共享模式锁定互斥锁的共享所有者数量超过了实现定义的最大数量,则 lock_shared 将阻塞执行,直到共享所有者的数量减少。所有者的最大数量保证至少为 10000。

对同一互斥锁的先前 unlock() 操作同步于(如 std::memory_order 中定义)此操作。

内容

[编辑] 参数

(无)

[编辑] 返回值

(无)

[编辑] 异常

在发生错误时抛出 std::system_error,包括来自底层操作系统的错误,这些错误会阻止 lock 满足其规范。在抛出任何异常的情况下,互斥锁不会被锁定。

[编辑] 备注

lock_shared() 通常不会直接调用:std::shared_lock 用于管理共享锁定。

[编辑] 示例

#include <chrono>
#include <iostream>
#include <mutex>
#include <shared_mutex>
#include <syncstream>
#include <thread>
#include <vector>
 
std::mutex stream_mutx;
void print(auto v)
{
    std::unique_lock<std::mutex> lock(stream_mutx);
    std::cout << std::this_thread::get_id() << " saw: ";
    for (auto e : v)
        std::cout << e << ' ';
    std::cout << '\n';
}
 
int main()
{
    using namespace std::chrono_literals;
    constexpr int N_READERS = 5;
    constexpr int LAST = -999;
 
    std::shared_mutex smtx;
    int product = 0;
 
    auto writer = [&smtx, &product](int start, int end)
    {
        for (int i = start; i < end; ++i)
        {
            auto data = i;            
            {
                std::unique_lock<std::shared_mutex> lock(smtx);
                product = data;
            } 
            std::this_thread::sleep_for(3ms);
        }
 
        smtx.lock(); // lock manually
        product = LAST;
        smtx.unlock();
    };
 
    auto reader = [&smtx, &product]()
    {
        int data = 0;
        std::vector<int> seen;
        do
        {
            {
                smtx.lock_shared(); // better to use: std::shared_lock lock(smtx);
                data = product;
                smtx.unlock_shared();
            }                                   
 
            seen.push_back(data);
            std::this_thread::sleep_for(2ms);
        }
        while (data != LAST);
 
        print(seen);
    };
 
    std::vector<std::thread> threads;
    threads.emplace_back(writer, 1, 13);
    threads.emplace_back(writer, 42, 52);
 
    for (int i = 0; i < N_READERS; ++i)
        threads.emplace_back(reader);
 
    for (auto&& t : threads)
        t.join();
}

可能的输出

127755840 saw: 43 3 3 4 46 5 6 7 7 8 9 51 10 11 11 12 -999
144541248 saw: 2 44 3 4 46 5 6 7 7 8 9 51 10 11 11 12 -999
110970432 saw: 42 2 3 45 4 5 47 6 7 8 8 9 10 11 11 12 -999
119363136 saw: 42 2 3 4 46 5 6 7 7 8 9 9 10 11 11 12 12 -999
136148544 saw: 2 44 3 4 46 5 6 48 7 8 9 51 10 11 11 12 12 -999

[编辑] 另请参见

锁定互斥锁,如果互斥锁不可用则阻塞
(公有成员函数) [编辑]
尝试以共享所有权锁定互斥锁,如果互斥锁不可用则返回
(公有成员函数) [编辑]
解锁互斥锁(共享所有权)
(公有成员函数) [编辑]