Потоковая связь между потоками

Question

Я разрабатываю многопоточный плагин для однопоточного приложения (имеющего API, не поддерживающий потоки).

Мой текущий плагин имеет два потока: главный, который является нитью приложения, и другой, который используется для обработки данных основного потока. Короче говоря, первый создает объекты, дает им идентификатор, вставляет их в карту, а иногда даже получает доступ и удаляет их (если приложение говорит так); второй - считывает данные с этой карты и изменяет объекты.

Мой вопрос: какие технологии я могу использовать, чтобы сделать мой плагин потокобезопасным?

Answer 1

Во-первых, вы должны определить, где может существовать race conditions. Затем вам нужно будет использовать какой-то механизм, чтобы обеспечить доступ к общим данным безопасным образом, следовательно, достижение Thread Safety.

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

Мое предложение состоит в том, что вы используете хорошо протестированную реализацию реализаций потоковой сети, а затем при необходимости добавьте дополнительную «защиту» для самих значений карты. Таким образом, вы гарантируете, что карта всегда находится в согласованном состоянии для обоих потоков, и если оба потока попытаются изменить одни и те же данные объекта (значения карты), данные не будут повреждены или останутся несогласованными.

Для самой карты вы можете искать структуры данных «Concurrent Hash Map» или «Atomic Hash Map» для C++ и посмотреть, обладают ли они хорошего качества и доступны для вашего компилятора/платформы. Хорошими примерами являются Intel TBBconcurrent_hash_map или Facebook follyAtomicHashMap. У них обоих есть преимущества и недостатки, и вам нужно будет проанализировать, что лучше для вашей ситуации.

Что касается объектов, которые содержит карта, вы можете использовать простые мьютексы (простые, блокировки, изменения данных, разблокировки), атомные операции (сложнее, только для простых типов данных) или другой метод, еще раз в зависимости от вашего компилятора/платформы и требования к скорости.

Надеюсь, это поможет!