Увеличьте shared_mutex с помощью условных авторов

Question

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

Проблема в операторе if(condition), так как это может быть оценено как истинное несколькими потоками, что заставляет их всех пытаться стать записывающими, даже если данные нужно записать только один раз.

class Test {
public:
    int getData() {
        boost::shared_lock<boost::shared_mutex> lock(access_);

        if(condition) {
            writeData();
        }

        // Do stuff
    }

    void writeData() {
        // Get exclusive access
        boost::upgrade_to_unique_lock<boost::shared_mutex> unique_lock(access_);

        // Do stuff
    }

private:    
    boost::shared_mutex access_;
}

Answer 1

Итак, я понял, что это работает приемлемым образом.По сути, я снимаю разделяемую блокировку, если необходима запись, и тогда функция записи получит уникальную блокировку.Получив уникальную блокировку в функции записи, он снова проверяет, чтобы убедиться, что операция записи по-прежнему необходима для обработки случая, когда несколько потоков считают, что им нужно записать данные.

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

class Test {
public:
    int getData() {
        boost::shared_lock<boost::shared_mutex> lock(access_);

        if(need_write) {
            lock.unlock();
            writeData();
            lock.lock();
        }

        // Do stuff
    }

    void writeData() {
        // Get exclusive access
        boost::unique_lock<boost::shared_mutex> unique_lock(access_);

        if(need_write) {
            return;
        }

        // Do stuff
    }
private:    
    boost::shared_mutex access_;
}