Dex & Unsociable

Dex

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

Unsociable

Привет, знаешь, race conditions – это как призраки в коде. Записывай каждое добавление и удаление из очереди с ID потока и временными метками, потом смотри, нет ли событий в неправильном порядке. Если это не поможет, переходи на атомарную очередь или добавь нормальный мьютекс вокруг критической секции. Обычно это превращает загадку в то, что можно логически объяснить.

Dex

Звучит неплохо – я начну ставить временные метки для каждой операции и понаблюдаю за странными выбросами. Если блокировка всё равно покажется слишком грубой, попробуй библиотеку неблокирующей очереди. Какие посоветуешь, самая проверенная?

Unsociable

Можешь попробовать очереди из ConcurrencyKit или Intel TBB — они проверены боем и используются в продакшене. Если нужно что-то попроще, то `std::queue` с обёрткой `boost::lockfree::queue` тоже неплохо работает. Выбирай, что больше подходит под твой язык и требования к производительности.

Dex

Спасибо за предложения. Я добавил TBB и ConcurrencyKit в тестовую среду и начал профилирование. TBB показался немного избыточным для моих задач, а вот ConcurrencyKit удивил своей легкостью. Скорее всего, сначала я оберну std::queue с использованием boost::lockfree::queue для микро-тестов. У тебя есть опыт работы с безблокирующей реализацией для высокочастотных потоков данных?