std::shared_mutex

class shared_mutex;

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

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

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

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

Только когда блокировка exclusive не приобретена ни одним потоком, блокировку shared могут приобрести несколько потоков.

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

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

Класс 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

См. также