如何从 Web 辅助角色调用共享辅助角色

Question

是否可以从 Web worker 调用共享工作线程？

你能给我举个例子吗？

就我而言，我有几个网络工作者，我需要在它们之间共享一个单例服务。

Answer 1

您可以使用类似于 https://stackoverflow.com/a/30796101/1319998 的技术。对于每个专用辅助角色，您可以创建一个指向同一脚本的共享工作线程对象，并将其端口传递给专用辅助角色。

请注意，对于同一脚本 URL，new SharedWorker(scriptUrl)不一定创建新的共享工作线程：它只是创建一个允许您与共享工作线程通信的新对象，并且仅在线程本身不存在时才创建该线程本身。

例如，以下内容创建 2 个 Worker 对象，每个对象创建一个单独的专用工作线程，以及 2 个SharedWorker对象，总共创建一个共享工作线程。共享工作线程的端口对象将传递给专用工作线程：

var sharedWorkerA = new SharedWorker("worker-shared.js");
sharedWorkerA.port.start();
var dedicatedWorkerA = new Worker("worker-dedicated.js");
dedicatedWorkerA.postMessage({sharedWorkerPort: sharedWorkerA.port, workerName: 'A'}, [sharedWorkerA.port]);
var sharedWorkerB = new SharedWorker("worker-shared.js");
sharedWorkerB.port.start();
var dedicatedWorkerB = new Worker("worker-dedicated.js");
dedicatedWorkerB.postMessage({sharedWorkerPort: sharedWorkerB.port, workerName: 'B'}, [sharedWorkerB.port]);

然后，专用工作线程可以在他们收到的端口对象上发布消息：

self.onmessage = function(e) {
  var workerName = e.data.workerName;
  var sharedWorkerPort = e.data.sharedWorkerPort;
  self.setInterval(function() {
    sharedWorkerPort.postMessage('sent from dedicated worker ' + workerName);
  }, 2000);
};

共享辅助角色可以接收它们：

var num = 0;
self.onconnect = function(e) {
  console.log('shared connect');
  var port = e.ports[0];
  port.onmessage = function(e) {
    num++;
    console.log('Received in shared worker: ', e.data);
    console.log('Number of messaged received:', num);
  };
};

我在其中放了一些额外的代码，只是为了表明确实有一个实际的共享工作线程正在运行。您可以在 http://plnkr.co/edit/RcxxY2EDIcclUegC82wG?p=preview 看到上述工作

Answer 2

SharedWorker构造函数目前在WorkerGlobalScope中不可用，因此您将无法像在 iframe 或窗口中那样构造实例。

您可以做的是，为每个工作线程创建一个消息通道，并使用它来在工作线程和共享工作线程之间进行通信。虽然这样做会否定对实际SharedWorker的需求，因为您也可以使用单个Worker来代替。

例：

var numWorkers = 4;
var sharedWorker = new Worker("worker-shared.js");
for(var i = 0; i < numWorkers; i++) {
  var dedicatedWorker = new Worker("worker-dedicated.js");
  var channel = new MessageChannel();
  dedicatedWorker.postMessage({sharedWorkerPort: channel.port1}, [channel.port1]);
  sharedWorker.postMessage({workerPort: channel.port2}, [channel.port2]);
}

演示