我已经开始探索 NetMQ 3.3.0.11 并遇到了使用 Poller 的问题。
我试图实现轮询器轮询大约 1 秒,然后停止并允许在它恢复轮询 1 秒之前完成其他操作,依此类推。
我有以下代码:
var poller = new Poller (client) { PollTimeout = 10 };
while (true)
{
for (var poll = 0; poll < 100; poll++)
{
poller.PollOnce ();
}
do_something;
}
我面临的问题是,在轮询期间,即使准备好接收消息,也不会触发 Client.ReceiveReady 事件。并提出了一个InvalidOperationException
陈述Poller is started
。
知道我做错了什么吗?