Nodejs工作线程共享对象/存储

Question

所以,我正在阅读有关nodejs的一些内容,当我遇到Worker Threads时,我感到非常惊讶.

在我看来,拥有线程是一个很好的加分,特别是如果你将它与共享内存访问结合起来.你可能已经想过了 - > SharedArrayBuffer......

是的,这就是我的想法.所以我想到的第一件事就是给它一点测试并尝试实现一个简单的store(现在是一个简单的对象),它将在线程之间共享.

问题是,(除非我在这里遗漏了一些东西)如何使用SharedArrayBuffer？从n个线程中访问对象？

我知道,对于一个简单的Uint32Array是可行的,但对于对象可以做什么？

起初我想把它转换Uint32Array成你可能会看到的声音,但即使看着该死的源代码也让我想哭...

const {
    Worker,
    isMainThread,
    workerData
} = require('worker_threads');

const store = {
    ks109: {
        title: 'some title 1',
        description: 'some desciption 1',
        keywords: ['one', 'two']
    },
    ks110: {
        title: 'some title 2',
        description: 'some desciption 2',
        keywords: ['three', 'four']
    },
    ks111: {
        title: 'some title 3',
        description: 'some desciption 3',
        keywords: ['five', 'six']
    }
}

const shareObject = (obj) => {

    let OString = JSON.stringify(obj);
    let SABuffer = new SharedArrayBuffer(Int32Array.BYTES_PER_ELEMENT * OString.length);
    let sArray = new Int32Array(SABuffer);

    for (let i = 0; i < OString.length; i++) {
        sArray[i] = OString.charCodeAt(i);
    }

    return sArray;

}

if (isMainThread) {

    const sharedStore = shareObject(store);

    console.log('[Main][Data Before]:', sharedStore.slice(-10));

    let w = new Worker(__filename, {
        workerData: sharedStore
    });

    w.on('message', (msg) => {
        console.log(`[Main][Thread message]: ${msg}`);
    });
    w.on('error', (err) => {
        console.error(`[Main][Thread error] ${err.message}`);
    });
    w.on('exit', (code) => {
        if (code !== 0) {
            console.error(`[Main][Thread unexpected exit]: ${code}`);
        }
    });

    setInterval(() => {
        // At some point you ll see a value change,
        // it's 'six' becoming 'sax' (big time!) 
        console.log('[Main][Data Check]:', sharedStore.slice(-10));
    }, 1000);

} else {

    let str = String.fromCharCode.apply(this, workerData);
    let obj = JSON.parse(str);

    obj.ks111.keywords[1] = 'sax'; // big time!

    let OString = JSON.stringify(obj);

    for (let i = 0; i < OString.length; i++) {
        workerData[i] = OString.charCodeAt(i);
    }

}

总之,nodejs 10.5.0中的线程之间的共享对象是否可能？怎么样？

Answer 1

ECMA脚本不包含共享对象，但具有SharedArrayBuffer。而且，您可以使用DataView和包装器直接在缓冲区中写入数据，从而实现这种行为：

// Shared value
class SharedPoint {
  constructor(array) {
    this.dataview = new DataView(array);
  }

  set x(value) {
    this.dataview.setUint8(0, value);
  }

  set y(value) {
    this.dataview.setUint8(1, value);
  }

  get x() {
    return this.dataview.getUint8(0);
  }

  get y() {
    return this.dataview.getUint8(1);
  }
}

// Usage

const buffer = new SharedArrayBuffer(2);

// Create two instances of shared point.
const point0 = new SharedPoint(buffer);
const point1 = new SharedPoint(buffer);

// Get initial values for point #1
console.log('x', point1.x); // 0
console.log('y', point1.y); // 0

// Update point #0
point0.x = 64;
point0.y = 32;

// Get changes in point #1
console.log('x', point1.x); // 64
console.log('y', point1.y); // 32

您可以创建可以处理字符串或类似C的结构的类。虽然SharedArrayBuffer是可转移的对象，但它可以在辅助进程和主进程之间共享。

?? 注意由于Spectre攻击，所有主要浏览器均禁用了SharedArrayBuffer，并在可能的情况下从版本67开始在Chrome中重新启用了它。检查浏览器对我的支持是否可以使用。