cout on extra thread - thread safety

Question

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

Задача: cout занимает некоторое время для выполнения и, следовательно, замедляет задачу, чувствительную к времени, в основном потоке.

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

Проблема с идеей: Векторы не являются потокобезопасными. Поэтому я беспокоюсь, что блокировка и разблокировка вектора займет почти столько же времени, сколько потребуется при вызове cout непосредственно в основной теме.

Вопрос: Есть ли альтернатива блокировке/разблокировке вектора? Я беспокоюсь о том, что блокировка вектора ошибочна? Не могли бы вы принять совершенно другой подход к решению проблемы?

Answer 1

В зависимости от того, как зависит от времени задача, я бы, вероятно, создал вектор выходов в потоке производителя, а затем передал весь вектор в потребительский поток (и повторял по мере необходимости).

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

Answer 2

Вы можете использовать идею, которую часто видят в программировании «прерывания» - отправлять данные из потока в кольцевой буфер. Затем в другом потоке печатайте из кольцевого буфера. Фактически, в «старые добрые времена» можно было написать кольцевой буфер без каких-либо «атомических» (и все еще можно делать на некоторых встроенных системах).

Но даже с атоматикой кольцевые буферы не сложны для записи. Существует одна реализация здесь: c++ threadsafe ringbuffer implementation (непроверенный, но на первый взгляд кажется ОК).