std::shared_mutex::lock

void lock();

(начиная с C++17)

Получает исключительное владение shared_mutex. Если другой поток удерживает исключительную или совместную блокировку того же shared_mutex, вызов lock будет блокировать выполнение до освобождения всех таких блокировок. Пока shared_mutex заблокирован в исключительном режиме, никакую другую блокировку любого типа также удерживать нельзя.

Если lock вызывается потоком, который уже владеет shared_mutex в любом режиме (исключительном или совместном), поведение не определено. Предшествующая операция unlock() над тем же мьютексом синхронизируется с этой операцией (согласно определению в std::memory_order).

Параметры

(нет)

Возвращаемое значение

(нет)

Исключения

При возникновении ошибок выбрасывает std::system_error, включая ошибки базовой операционной системы, которые препятствуют соответствию lock установленным требованиям. В случае выбрасывания любого исключения мьютекс не блокируется.

Примечания

lock() обычно не вызывается напрямую: для управления исключительной блокировкой используются std::unique_lock, std::scoped_lock и std::lock_guard.

Пример

#include <chrono>
#include <iostream>
#include <mutex>
#include <shared_mutex>
#include <syncstream>
#include <thread>
#include <vector>

std::mutex stream_mutx;
void print(auto const& 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); // better than:
                                                                // smtx.lock();
                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
        {
            {
                // better to use:
                std::shared_lock lock(smtx); // smtx.lock_shared();
                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

См. также

try_lock	пытается заблокировать мьютекс и возвращает управление, если мьютекс недоступен (открытая функция-член)
unlock	снимает блокировку мьютекса (открытая функция-член)
lock_shared	блокирует мьютекс для совместного владения; если мьютекс недоступен, ожидает (открытая функция-член)

© cppreference.com
Licensed under the Creative Commons Attribution-ShareAlike Unported License v3.0.
https://en.cppreference.com/cpp/thread/shared_mutex/lock