nodejs addon async callback with libuv

Question

我有一个节点js服务，可以调用本机C库。本机库，反复且连续地触发事件。这些事件传递到 C 回调函数。我的目标是从这个本机 C 回调调用 Javascript 回调。

根据我的阅读，我正在使用uv_async_init和uv_async_send来实现这一目标。

我遇到的问题是我的本机 C 回调函数被调用了很多次，并且在那里调用了很多次uv_async_send，但传递给 uv_async_init 的函数只被调用一次，并且仅在我的程序退出时调用。

这是我的 C 代码：

====

=======================================================

#include "jsaudio.h"
#include <iostream>
using namespace v8;
static void recordAudioCallback(int index);
void asyncmsg(uv_async_t* handle);
Callback* cbPeriodic;
uv_async_t async;
uv_loop_t* loop;
NAN_METHOD(createEngine) {
std::cout << "==> createEnginen" ;
}
void createAudioRecorder(const Nan::FunctionCallbackInfo<v8::Value>& info) {
std::cout << "==> createAudioRecordern";
}
void startRecording(const Nan::FunctionCallbackInfo<v8::Value>& info) {
std::cout << "==> startRecordingn";
cbPeriodic = new Callback(info[0].As<Function>());
loop = uv_default_loop();
uv_async_init(loop, &async, asyncmsg);
}
void asyncmsg(uv_async_t* handle) {
std::cout << "==> asyncmsg n";
Nan::HandleScope scope;
v8::Isolate* isolate = v8::Isolate::GetCurrent();
Local<Value> argv[] = { v8::String::NewFromUtf8(isolate, "Hello world") };
cbPeriodic->Call(1, argv);
}
/* This my callback that gets called many times, by a native library*/
static void recordAudioCallback(int index) {
std::cout << "==> recordAudioCallback " << index << "n";
uv_async_send(&async);
}

====

==========================================================这是我的测试节点.js调用上述本机代码

的代码

const jsAudio = new JsAudio({sampleRate: 48000, bufferSize: 8192})
function Test () {
jsAudio.createEngine();
jsAudio.createAudioRecorder();
jsAudio.startRecording(function(error, result) {
if (error) {
console.log('startRecording failed: ' + error);
} else {
console.log('startRecording result: ' + result);
}
});
}
Test();
var waitTill = new Date(new Date().getTime() + 3 * 1000);
while(waitTill > new Date()){}
jsAudio.shutdown();
console.log('program exit...');

====

===============================================================这是输出：

==> createEngine
==> createAudioRecorder
==> startRecording
==> recordAudioCallback 0
==> recordAudioCallback 1
==> recordAudioCallback 0
==> recordAudioCallback 1
==> recordAudioCallback 0
==> shutdown
program exit...
==> asyncmsg 
startRecording failed: Hello world

====

==================================================================为什么 asyncmsg 只被调用一次！即使 recordAudioCallback 被调用了好几次！为什么在程序退出后调用它！

任何帮助，不胜感激。

Answer 1

node.js中Javascript代码的实际执行是单线程的。这意味着回调不能在一些已经执行的JS代码中间执行。

您的示例代码包含一个繁忙循环，该循环连续运行一段时间，然后程序结束。在该循环执行时，没有机会执行回调。

尝试将其替换为调用setTimeout，以在所需的时间间隔设置超时。像这样：

const jsAudio = new JsAudio({sampleRate: 48000, bufferSize: 8192})
function Test () {
jsAudio.createEngine();
jsAudio.createAudioRecorder();
jsAudio.startRecording(function(error, result) {
if (error) {
console.log('startRecording failed: ' + error);
} else {
console.log('startRecording result: ' + result);
}
});
}
Test();
setTimeout(function() {
jsAudio.shutdown();
console.log('program exit...');
}, 3000);

请注意，即使对 setTimeout 的调用会立即返回，程序也不会退出。这是因为 node.js 有一个事件循环，只要有一些挂起的计时器或其他事件等待处理，它就会继续。

有关事件循环的说明，请参阅节点.js文档的此部分。