如何从 web worker 调用 shared worker?

How to call shared worker from the web worker?

是否可以从 Web Worker 调用 Shared Worker?

能举个例子吗

在我的例子中,我有几个网络工作者,我需要在他们之间共享一个单例服务。

SharedWorker 构造函数当前在 WorkerGlobalScope 中不可用,因此您将无法像在 iframe 或 window 中那样构造实例。

你可以做的是,为你的每个worker创建一个MessageChannel,并用它来在worker和sharedWorker之间进行通信。尽管这样做会否定对实际 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]);
}

Demo

您可以使用类似于 中的技术。对于每个专用工作器,您可以创建一个共享工作器对象,指向相同的脚本,并将其端口传递给专用工作器。

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

例如,下面创建了 2 个 Worker 个对象,每个对象创建一个单独的专用工作线程,以及 2 个 SharedWorker 个对象,它们总共创建一个共享工作线程。共享worker的端口对象传递给dedicated worker:

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]);

专用工作人员然后可以 post 在他们收到的端口对象上发送消息:

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

看到上面的工作