javascript - 如何在数组中向网络工作人员创建/发布消息

Question

问题很简单:

示例:

For (iterate based on amount of cores){
   Let worker = workers[I]
   Worker.postmessage
}

示例结束。

免责声明:此示例仅显示预期的最终结果，绝不是所谓的“工作条件”。另请注意，上面使用的方法不会返回“workers[iterator]”的工作人员，而只是未定义。

目标:创建工作方法:

1:制作未知数量的工作人员数组(基于核心)。

2:构建该数组后，向每个工作人员发送一条消息并返回结果(未定义除外)。

注意:我确实有一个关于它不起作用的假设:

1:Web Worker 被创建，并且只能通过创建它们的事件进行访问，并且其唯一接受的是 onmessage“事件”处理程序。

• 与我的假设相反，有些东西与上面所写的内容很相似，例如允许线程池和其他过程的 thread.js。

这是我问的主要原因，因为我确实知道这是可能的，但想要一个简单的答案。

感谢您的宝贵时间。

Answer 1

这是一个例子:

function createWorker (workerScript) {
    const blob = new Blob([`(${workerScript})(self)`], {type: 'application/javascript'});
    return new Worker(URL.createObjectURL(blob));
};

function workerCode (self) {
    self.onmessage = function (message) {
        postMessage(`Data from worker: ${message.data}`);
    };
};

// assuming that you will send only one message to the worker,
// and that the worker will produce only one message too.
function workerPromise (worker, message) {
    const promise = new Promise((resolve, reject) => {
        worker.onmessage = resolve;
    }).then(message => message.data);
    worker.postMessage(message);
    return promise;
}

(async () => {
    const workers = [];
    for (let i = 0; i < navigator.hardwareConcurrency; i++) {
        workers.push(createWorker(workerCode));
    }

    const results = await Promise.all(
        workers.map((w, index) => workerPromise(w, `worker ${index}`))
    );

    console.log(results);
})();