云风的 BLOG

最近对网络消息分发做了点小优化，方法值得记录一下：

当有若干消息需要处理时，简单的方案是把消息放到一个队列里，然后依次从队列取出来处理。

但这么做有一个小问题：单条的消息处理过程可能被阻塞挂起，如果等待一条消息处理完再处理下一条就会因为上一条消息的阻塞而延缓之后的消息处理。

为了避免这种情况，我们可以用 skynet.fork 启动多个 coroutine 来分别处理队列消息。但这样做会增加许多 coroutine 。如果消息处理流程并不会阻塞，这种方法又有点浪费（本可以用一个 coroutine 搞定）。

最好的方法是：一旦 coroutine 挂起，就立刻开启新的 coroutine 继续处理队列中的消息；如果没有挂起而是处理完了，就接着处理下一条。但是，这样就需要修改调度器了。

我想到一个折中的方案：

每次判断队列是否为空，如果不为空，就调用 skynet.fork 出自己这个函数处理这个消息队列。并接下来马上循环处理消息队列中的消息。

这样，如果消息处理中不会挂起的话，fork 出来的 coroutine 会发现队列已经为空立刻退出；如果消息处理挂起，那么 fork 的 coroutine 会接着处理没处理的消息。由于消息队列只有一个，同一条消息不会被 pop 两次，所以整个流程是正确的（且保证了消息处理开始时点的次序）。

创建的 coroutine 的个数也仅比上面提到的理想方案多一个而已。

最后， 计划在今年内组织一次 skynet 的线下交流活动。地点在广州，时间未定。有兴趣的同学可以去邮件列表报名。