nodejs中实现阻塞实例

2020-06-17 06:47:28易采站长站整理

    });
    Fiber.yield();
    console.log(html);
}).run();

yield()、 run()这两个方法还不了解的同学,请自行查阅《fibers in node》。

fibers的运行并不在node进程中,所以在fibers内部实现阻塞对node整体的性能并没有影响。而且实现起来也是相当容易,只需要在想阻塞的时候,把fiber yield掉。需要继续运行,则执行 run()恢复fiber。在上面的例子中,我们希望当http.get请求发起时阻塞当前程序,当所有数据接收完成时,恢复程序。于是我们在调用http.get后使用 Fiber.yield()中断此fiber。在对response的监听中,如果触发 end事件表明数据传输完成,于是在 end的回调函数中,调用 Fiber.current.run()恢复fiber,这样,后续的代码就以同步的方式拿到http.get请求的数据。

上面的示例只是提供一种思路。如果对这种思路进行一些抽象封装,比如说,对有接受回调函数为参数的异步方法进行一步柯里化,在调用后中断,并劫持回调函数,以恢复程序的代码为回调函数。获取异步数据后,再程序触发预定的回调函数,这样基本能实现异步方法同步化。这段说得比较乱,基本上就是 fibers/future的实现思路,如果有兴趣,请参考其源代码。