Здравствуйте, VVV, Вы писали:

VVV>3. Самый главный недостаток реализации: ты вызываешь link.mConsumer->Consume(link.mKey, value); из своего потока, а не из потока консумера! Это значит, что Tls (thread local storage) консумера будет этому консумеру _недоступен_. И потоконебезопасные библиотеки невозможно будет использовать в этом коде.
А как будет выглядеть вызов из потока консьюмера?