Если вышеприведенный подход является способом, который вы не хотите использовать, то можно сделать следующее:
1)
Создайте поток с автономным последовательным портом -сканером, оборудуйте этот поток PAIR/PAIR или PUSH/PULL (как видно из потока сканера портов side) соединение с основным, лучше всего использовать транспортный класс с нулевыми или низкими издержками ~ inproc:// или ipc:// (транспортный класс tcp:// просто тратит слишком много служебных данных для доставки межпотоковой сигнализации / обмена сообщениями). Сделайте так, чтобы этот поток сканера отправлял все, что вам нужно, по этой восходящей линии связи на главную, когда вы чувствуете, что это уместно.
2)
Создайте нить с помощью автономного nanomsg -сканера, оборудуйте эту нить PAIR/PAIR или PUSH/PULL (как видно из соединение со стороной резьбы гнезда) с основным, лучше всего использовать транспортный класс с нулевой или низкой служебной нагрузкой ~ inproc:// или ipc://. Сделайте так, чтобы этот поток сканера отправлял все, что вам нужно, по этой восходящей линии связи на главную, когда вы чувствуете, что это уместно.
3)
Оснастите main() обоими соответствующими контрагентами (2x PAIR -s или 2x PULL -s), как определено в 1) и 2), и поддержите эту инфраструктуру плоскости сигнализации / обмена сообщениями между потоками в рабочем состоянии.
4)
Наслаждайтесь "комфорт" тривиального вызова блокировки на .poll() в main(){...} (как вы хотели выше, тогда как я профессионально выступаю за использование неблокирующего кода, всегда ... но также признавать, но не уважать ваше выраженное выше желание потерять свой собственный элемент управления кодом, во время неопределенно долгого ожидания события разблокирования - если оно когда-либо произойдет)
5)
Если .poll() получил какое-либо сообщение, выполните aRetCODE = nn_recv( aS, &B, aBsz, NN_DONTWAIT ); чтение соответствующей сигнальной восходящей линии связи с любого из потоков сканера.
6)
Loop.