如何在事件处理程序中进行asynchronous调用?

我试图写一个自定义的摩卡记者,与一个HTTP API的第三方集成。

我接受了自定义记者( https://github.com/mochajs/mocha/wiki/Third-party-reporters )的基本示例,并试图在启动事件处理程序中添加对API的调用。 然而,我的HTTP请求callback到第三方似乎从未触发。 示例代码如下所示。

我已经testing了请求代码在其他上下文中按预期工作,它似乎是在摩卡记者的事件处理程序内,没有任何反应。

注意 – 请原谅当前的黑客等待callback的结果,我只是想确保我没有退出之前,callback有机会开火,我会收拾起来,当我得到它的工作!

var request = require('request'); module.exports = function (runner) { var passes = 0; var failures = 0; runner.on('start', function() { var callbackFired = false; request('http://www.testapi.com', function (error, response, body) { callbackFired = true; }); while(!callbackFired){ console.log('waiting...'); } }); runner.on('pass', function(test){ passes++; console.log('pass: %s', test.fullTitle()); }); runner.on('fail', function(test, err){ failures++; console.log('fail: %s -- error: %s', test.fullTitle(), err.message); }); runner.on('end', function(){ console.log('end: %d/%d', passes, passes + failures); process.exit(failures); }); }; 

       

网上收集的解决方案 "如何在事件处理程序中进行asynchronous调用?"

你的callback从不执行,因为你的代码没有给它一个执行的机会。 有一个基本的原则,你要么不知道JavaScript的,或者你暂时忘记了: JavaScript代码不被抢占 。 这个代码保证是一个无限循环:

 while(!callbackFired){ console.log('waiting...'); } 

为什么? 首先,因为request必须在callbackFired成为true之前实际完成HTTP请求。 当你调用request ,它所做的是发起HTTP请求,并logging请求完成时,应该调用callback。 其次,记得我说上面没有抢占? JavaScript VM在callbackFired变为true之前进入循环,并开始执行循环。 HTTP请求可能会在循环执行期间完成,但callback仍然不会执行。 为什么? 因为只要循环正在执行(不抢占!),JavaScript VM就不能控制callback。 为了使VM能够控制callback,你的代码必须返回,以便最终由VM启动的所有function都返回,然后VM有机会处理HTTP完成。

更正式的说法(参见这里的文档 ,你的代码不会给VM的事件循环机会来处理HTTP完成事件,并控制你的callback。

这就是说,还有其他的考虑让你的记者asynchronous工作:

  1. 不要打电话给你的记者。 如果在进程退出时需要事件发生,可以使用process.on('exit', ...

  2. 事件处理程序同步运行,因此不能让runner.on('start', ...)等待asynchronous操作的结果。

    你可以做的是有runner.on('start', ...)启动一个asynchronous操作,返回一个承诺,然后在runner.on('pass', ...) (和'fail' )使用这个承诺来执行更多的asynchronous操作。 例如,

     module.exports = function (runner) { var passes = 0; var failures = 0; var init; runner.on('start', function() { init = async_op_returning_promise(...); }); runner.on('pass', function(test){ passes++; init.then(function (results) { // do something more... }); });