Intereting Posts

答复缓慢,答复node.js

我是全新的node.js和,我觉得我做了一些不正确的事情,但我有一个更好的答案search,然后有其他语言出于某种原因。 基本上我使用一个包裹c ++插件的节点做一些工作,然后我想通过websocket发送它,然后再对其进行一些额外的parsing。 当额外的parsing是同步完成时,立即发送(如预期)。 当我在一个承诺(这是第三方模块为我所做的)承诺工作之后,调用完成的callback花费很长的时间。 喜欢5-10秒。 代码如下:

var addon = require('...'); // Node wrapped C++ module ... var server = http.createServer(){...}; var ios = io.listen(server); function someFunction(args) { console.log("Preparing to call some function"); someOtherFunction(args).then(funtction(val) { console.log("Sending val over websocket...."); ios.sockets.emit('thing', val); } } function someOtherFunction(args) { return new Promise(function(resolve, reject) { //logic resolve(someVal); console.log("Done with someOtherFunc"); } } ios.sockets.on('connection', function(socket){ console.log("Conneced"); // This does some work on a different thread. Eventually reposts to event loop and calls callback addon.doThing("someVal", someFunc); socket.on('disconnect', function() { console.log("Disconnected"); }); }); 

输出:

 Connected Preparing to call some function... Done with someOtherFunc; <variable delay sometimes up to 5-10 seconds> Sending val over websocket. 

someFunction的多次callback可能会在第一次调用someOtherFunction之前发生。 这些都是主事件循环发布的事件,所以我不相信任何东西都阻挡在那里。 输出:

 Connected Preparing to call some function... Done with someOtherFunc; <1 second delay> Preparing to call some function... Done with someOtherFunc; <1 second delay> Preparing to call some function... Done with someOtherFunc; <1 second delay> <variable delay sometimes up to 5-10 seconds> Sending val over websocket. Sending val over websocket. Sending val over websocket. 

所以我的问题原来的想法是,当解决scheme被调用,然后立即调用callback。 但是这看起来并不像这样。 有什么东西是触发callback最终触发,但我不知道什么,它似乎是随机的,当它实际上。 任何帮助,将不胜感激!

C ++插件代码:

 class NodeWrapper { public: static NodeWrapper& GetInstance() { static NodeWrapper mInstance; return mInstance; } ~NodeWrapper() { uv_close((uv_handle_t*) &mNodeAsyncEventLoop, NULL); }; static void SendToNode(uv_async_t *handle) { GetInstance().SendToNode(); } void SendToNode() { uv_mutex_lock(&mMutex); swap(pushQueue, popQueue); uv_mutex_unlock(&mMutex); while(!popQueue.empty()) { Data* pData = popQueue.front(); Isolate* isolate = Isolate::GetCurrent(); HandleScope scope(isolate); const unsigned argc = 1; Local<Value> argv = { node::Buffer::New(isolate, pData->mData, pData->mLen, DataDeleter, NULL).ToLocalChecked() }; Local<Function> cb = Local<Function>::New(isolate, mNodeCB); cb->Call(isolate->GetCurrentContext()->Global(), argc, &argv); popQueue.pop(); } log << "Done with Callback!" << std::endl; } void SendOnData(const void* pData, DWORD dwLen) { log << "Callback received!" << std::endl; if(dwLen > 0) { uv_mutex_lock(&mMutex); pushQueue.push(new Data(pData, dwLen)); uv_mutex_unlock(&mMutex); uv_async_send(&GetInstance().mNodeAsyncEventLoop); } }; static NodeWrapper mInstance; UniquePersistent<Function> mNodeCB; private: NodeWrapper() { uv_async_init(uv_default_loop(), &mNodeAsyncEventLoop, &NodeWrapper::SendToNode); uv_mutex_init(&mMutex); }; DATA_QUEUE pushQueue; DATA_QUEUE popQueue; uv_mutex_t mMutex; uv_async_t mNodeAsyncEventLoop; }; void doThing(const FunctionCallbackInfo<Value>& args) { Isolate* isolate = Isolate::GetCurrent(); HandleScope scope(isolate); auto f = std::bind(&NodeWrapper::SendOnData, &NodeWrapper::GetInstance()); DoThingAnotherThreadAndCallCallback(f); NodeWrapper::GetInstance().mNodeCB = UniquePersistent<Function>(isolate, Local<Function>::Cast(args[1])); } 

输出更新:

 22:01:57.831645 - Callback received Preparing to call some function.... Done with someOtherFunc 22:01:57.839711 - Done with Callback! 22:01:57.918472 - Callback received Preparing to call some function.... Done with someOtherFunc 22:01:57.927344 - Done with Callback! Sending val over websocket.... Sending val over websocket.... 

Solutions Collecting From Web of "答复缓慢,答复node.js"

Promise .then()callback决不会立即调用resolve() 。 相反,它们总是被asynchronous调用。 这提供了统一的asynchronous行为,无论是同步还是asynchronous调用parsing,从而使调用者的生活变得轻松许多。

Promise等待,直到当前执行线程中的其他代码已经执行完毕,堆栈帧已经被清除回“平台代码”。 然后,调用.then()callback。 如果在执行线程中做了很多其他的事情,那么在调用.then()处理程序之前可能会有一段延迟。

我通过从本地v8 Promise切换到蓝鸟诺言解决了这个问题。 原生v8 Promise由Microtask队列处理,我不知道如何处理c ++插件(我永远不能得到一个好的堆栈跟踪看到),但它看起来像microtask队列变得饿死,直到它最终运行一定的事件后刷新它(仍然不确定)。 蓝鸟使用SetImmediate和它立即处理,为我解决了这个问题。

进一步阅读阅读: https : //github.com/nodejs/node-v0.x-archive/issues/7714

这是在v0.12“固定”,我实际上使用io.js v3.2.0。 我不是100%确定这是相同的问题还是不同的问题。 无论哪种方式,我现在坚持蓝鸟