Использование zmq socket в функции обратного вызова

Question

У меня есть функция обратного вызова, которая будет вызвана в потоке, к которому у меня нет доступа или управления (библиотека, созданная этим потоком, и требует, чтобы я подвергал функцию обратного вызова этому нить). Поскольку разъем zmq не поточно, вот что я делаю:

void callback() { 
    zmq::socket_t tmp_sock(...); // create a socket which will be used only once 
    ... 
} 

Однако обратный вызов в настоящее время вызываются очень часто (сотни раз в секунду). Есть ли лучшее решение для более эффективного использования сокета? Я спросил об этом, потому что Руководство говорит: Если вы открываете и закрываете множество сокетов, это, вероятно, признак того, что вам нужно перепроектировать ваше приложение.

Редактировать: Основано на ответе @ raffian. A thread_local static (доступно в C++ 11) переменная в функции обратного вызова работает нормально.

Answer 1

я задал тот же вопрос, но в Java:

Принципы те же: предварительно инициализировать пул рабочих потоков, каждый со специальным гнездом, готовый к использованию для чтения/записи. В примере Java я использую ThreadLocal; Я полагаю, что в C++ вы можете использовать #include <boost/thread/tss.hpp>. Этот подход согласуется с руководством ZeroMq; используйте розетки только в потоках, которые их создали.

Я не ++ программист C, но если вы используете этот подход, вы должны сделать что-то вроде этого:

void callback() { 
    workerPool.doTask(new Task(args here)); 
    ... 
} 

Создать Task, с аргументами, и отправить его в workerPool, где он назначен потоку с выделенным сокетом. Вы хотите создать рабочий пул с достаточным количеством потоков для размещения нагрузки, тем не менее, параллелизм не должен вызывать беспокойства.