std:: shared_mutex

Класс shared_mutex является примитивом синхронизации, который может использоваться для защиты общих данных от одновременного доступа несколькими потоками. В отличие от других типов мьютексов, обеспечивающих эксклюзивный доступ, shared_mutex имеет два уровня доступа:

• shared - несколько потоков могут совместно владеть одним и тем же мьютексом.

• exclusive - только один поток может владеть мьютексом.

Если один поток получил эксклюзивную блокировку (через lock , try_lock ), никакие другие потоки не могут получить блокировку (включая общую ).

Если один поток получил разделяемую блокировку (через lock_shared , try_lock_shared ), никакой другой поток не может получить эксклюзивную блокировку, но может получить разделяемую блокировку.

Только когда эксклюзивная блокировка не была получена ни одним потоком, общая блокировка может быть получена несколькими потоками.

В одном потоке одновременно может быть захвачена только одна блокировка ( shared или exclusive ).

Общие мьютексы особенно полезны, когда общие данные могут безопасно читаться любым количеством потоков одновременно, но поток может записывать те же данные только тогда, когда никакой другой поток не читает и не записывает в то же время.

Класс shared_mutex удовлетворяет всем требованиям SharedMutex и StandardLayoutType .

Типы членов

Функции-члены

Пример

#include <iostream>
#include <mutex>
#include <shared_mutex>
#include <syncstream>
#include <thread>
class ThreadSafeCounter
{
public:
    ThreadSafeCounter() = default;
    // Multiple threads/readers can read the counter's value at the same time.
    unsigned int get() const
    {
        std::shared_lock lock(mutex_);
        return value_;
    }
    // Only one thread/writer can increment/write the counter's value.
    void increment()
    {
        std::unique_lock lock(mutex_);
        ++value_;
    }
    // Only one thread/writer can reset/write the counter's value.
    void reset()
    {
        std::unique_lock lock(mutex_);
        value_ = 0;
    }
private:
    mutable std::shared_mutex mutex_;
    unsigned int value_{};
};
int main()
{
    ThreadSafeCounter counter;
    auto increment_and_print = [&counter]()
    {
        for (int i{}; i != 3; ++i)
        {
            counter.increment();
            std::osyncstream(std::cout)
                << std::this_thread::get_id() << ' ' << counter.get() << '\n';
        }
    };
    std::thread thread1(increment_and_print);
    std::thread thread2(increment_and_print);
    thread1.join();
    thread2.join();
}

123084176803584 2
123084176803584 3
123084176803584 4
123084185655040 1
123084185655040 5
123084185655040 6

Смотрите также