>Shtolz,сегодня, 04:18 [17472680]
>...Из внешнего источника мне приходит ...

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

С уважением,
Владимир.

>Shtolz, вчера, 10:08 [17475152]
>Простите за невежество, но шо це таке?

Пример на C#

using System;
namespace ns_Реп {
//--Класс для работы с циклическим массивом ошибок
//================================================
static class цмо { //-- ЦиклическийМассивОшибок
private static int intУЗ=0; //-- Указатель записи (индекс вектора)
private static int intУЧ=0; //-- Указатель чтения (индекс вектора)
private static int intРазмерЦМ=256; //-- размер циклического массива в сообщениях
private static byte[][] цм=new byte[intРазмерЦМ][];

//-- Читаем ошибку из циклического массива ошибок
//-- выход: byte[] - байтовая строка ошибки
//=================================================
public static byte[] fЧтениеОшибки() {
byte[] abb=null;
lock(цм){
if(intУЗ!=intУЧ){ //-- Есть не обработанное сообщение
abb=цм[intУЧ];
if(++intУЧ==intРазмерЦМ) intУЧ=0; //-- Здесь можно и так intУЧ = ++intУЧ & 255
}
}
return abb;
}
//-- Пишем ошибку в циклической массив ошибок
//-- byte[] - байтовая строка ошибки
//-- если byte[] ответа =null, то штатно
//=================================================
public static byte[] fЗаписьОшибки(byte[] bbb) {
lock(цм){
цм[intУЗ]=bbb;
//-- Корректируем указатели
if(++intУЗ==intРазмерЦМ) intУЗ=0; //-- Здесь можно и так intУЧ = ++intУЧ & 255
if(intУЗ==intУЧ) {if(++intУЧ==intРазмерЦМ) intУЧ=0;} //-- Здесь можно и так if(intУЗ==intУЧ) intУЧ = ++intУЧ & 255
}
return null;
}
}

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

С уважением,
Владимир