关于Nodejs通过ffi调用多线程库

要通过 Node.js 的 ffi 库调用一个多线程的 C 库，并且希望在 JavaScript 层处理这些多线程产生的事件，需要特别注意如何管理和触发这些回调。以下是一个简化的示例来说明如何实现这一点。

示例代码

首先，我们需要定义一些必要的类型和函数：

const ffi = require('ffi-napi');
const ref = require('ref-napi');

// 定义一些类型
const voidPtr = ref.refType('void');
const int = 'int';
const voidFunc = 'void';

// 定义 C 库中的函数签名
const lib = ffi.Library('vendor/linux_x64/libdtp', {
    'player_register_all': [voidFunc, []],
    'dtplayer_init': ['pointer', ['pointer']], // 返回一个指针
    'dtplayer_start': [int, [voidPtr]],        // 接受一个指针作为参数
    'register_callback': [voidFunc, [voidPtr]] // 注册回调函数
});

// 定义回调函数类型
const callbackType = ffi.Function(voidFunc, [voidPtr]);

// 创建一个播放器类
class DTPPlayer {
    constructor(params) {
        this.params = params;
        this.callback = null;

        // 初始化播放器并注册回调
        this.handle = lib.dtplayer_init(this.params.ref());
        this.registerCallback();
    }

    registerCallback() {
        const self = this;
        this.callback = new callbackType(function(state) {
            console.log("Callback triggered with state:", state);
            if (self.emit) {
                self.emit('update_info', state);
            }
        });
        lib.register_callback(this.callback.address());
    }

    play() {
        lib.player_register_all();
        lib.dtplayer_start(this.handle);

        // 播放开始后，事件循环继续运行
        process.nextTick(() => {
            console.log("Playback started");
        });
    }

    bindEvents() {
        this.on('playing', () => {
            console.log("Receive playing signal");
        });

        this.on('update_info', (state) => {
            console.log("Current time:", state.deref().cur_time);
        });
    }

    on(event, listener) {
        if (!this.listeners) {
            this.listeners = {};
        }
        if (!this.listeners[event]) {
            this.listeners[event] = [];
        }
        this.listeners[event].push(listener);
    }

    emit(event, data) {
        if (this.listeners && this.listeners[event]) {
            this.listeners[event].forEach(listener => listener(data));
        }
    }
}

// 使用示例
const params = {
    update_cb: null
};

const player = new DTPPlayer(params);
player.play();
player.bindEvents();

解释

1. 类型定义:

   • ffi.Library 中定义了 C 库中的函数及其参数类型。
   • callbackType 定义了一个函数指针类型，用于接收 C 库中的回调函数。

2. DTPPlayer 类:

   • 构造函数初始化播放器并注册回调函数。
   • registerCallback 方法创建并注册回调函数，该回调函数将捕获来自 C 库的数据并在 JavaScript 层触发事件。
   • play 方法启动播放并确保事件循环不会立即退出。
   • bindEvents 方法绑定事件监听器。
   • on 和 emit 方法用于管理事件系统。

3. 事件处理:

   • 在 registerCallback 中，回调函数被设置为在 C 库中触发时调用，并在 JavaScript 层触发相应的事件。

这样，即使 C 库在后台启动多个线程，你也可以在 JavaScript 层正确地处理这些线程产生的事件。

沒用過這個library 以下只是猜測…

我想 <pre> this.priv = dtplib.dtplayer_init(this.para.ref()); dtplib.dtplayer_start(this.priv); </pre> 這兩句 把dtp_cb() 和 dtplayer_start() 勾起來 觸發數次 後面退出 應該是都播放完了吧? 你可以用async() 掛一個 onEnd Handler() 驗證一下 <pre><code> dtplib.dtplayer_start.async(???, function (err, res) { //empty });

dtplib.dtplayer_start(priv, function callback(err, res) { if (err) throw new Error(“oops”) console.log(“player end”);. }); </code></pre>