1

введите сюда описание изображенияЕсть поток-писатель, есть много потоков читателей. Вопрос в том, как реализовать ситуацию, когда поток-писатель пишет/обновляет данные в некотором поле, затем ждет, пока все читатели обработают эти данные (в этот момент писатель может рассчитывать обновление данных), когда они обработают, соответственно читатели НЕ пытаются повторно обработать уже обработанные данные, а ждут пока писатель обновит данные. Затем писатель сигналит читателям, что данные обновлены и те принимаются за работу.

Используется C++, MS VS 15/17, многопоточность стандартной библиотеки.

Пока моя идея сводится к использованию mutex (?, что если всех этих потоков много ~100000, нет ли ограничений на кол-во мьютексов) и condition variable. Вероятно, есть другое наиболее оптимальное решение и готовое.

12
  • Используйте pipes. Pipes позволяет писать / читать любому к-ву потоков
    – nick_n_a
    Commented 1 сент. 2017 в 12:30
  • nick_n_a, а pipes в стандартной библиотеке есть? как они там называются?
    – Jens
    Commented 1 сент. 2017 в 12:33
  • 1
    А зачем Вам много мьютексов? Одного не хватит?
    – ixSci
    Commented 1 сент. 2017 в 12:34
  • 1
    Поставьте мутекс/семафор, где писатель записывает что 1 (или n) можно прочесть, а читатели убирают признак (уменьшают n).
    – nick_n_a
    Commented 1 сент. 2017 в 12:36
  • ixSci, извиняюсь, неточно написал - каждый писатель одновременно и читатель других. Т.е. в каждом потоке выполняется и читательская и писательская функция - память у всех своя, мьютексы тоже. Потоков много - мьютексов тоже много потребуется.
    – Jens
    Commented 1 сент. 2017 в 12:37

1 ответ 1

2

Если рассматривать только приведенный Вами кусок общей схемы с 1 писателем и несколькими читателями, то Вам подойдет для решения блокировка чтения-записи, суть ее в следующем :

  • только 1 поток может захватить ее на запись, все остальные в это время ждут;
  • на чтение ее могут захватить сразу несколько потоков, и читать не мешая друг другу;
  • обычно приоритет "писателей" выше, что не дает читателям захватить блокировку навечно (но тут уже могут быть нюансы, надо реализацию смотреть).

Я пользовалась этим примитивом из библиотеки pthread, однако это подойдет только для Unix. Для Win можно посмотреть примеры использования boost::shared_mutex тут, (вроде он появился и в 17 стандарте), или класс ReaderWriterLock тут.

2
  • А можете дать пример на задачу, в которой приоритет писателей каким-то образом установлен выше? Сейчас решаю эту задачу с использованием shared_mutex, и приоритет нужен не на уровне потоков (native_handle() и ко.), а на уровне разделения ресурса.
    – Jens
    Commented 7 окт. 2017 в 8:11
  • ru.stackoverflow.com/questions/727684/… - вот мой вопрос по данной теме
    – Jens
    Commented 7 окт. 2017 в 8:12

Ваш ответ

Нажимая «Отправить ответ», вы соглашаетесь с условиями пользования и подтверждаете, что прочитали политику конфиденциальности.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.