网络工作者突然终止

Question

我在 chrome 上启动了一个 web worker，它有一个简单的函数，可以使用 setTimeout 重复调用。令人惊讶的是，在该函数被调用了大约 1000 次后，Web Worker 终止了。谁能解释为什么？我猜 chrome 正在做一些优化。

webworker.js

function hi() {
    postMessage('1');
    setTimeout(hi, 1);
}
hi();

ma​​in.js

var blob = new Blob([code]);
var blobURL = window.URL.createObjectURL(blob);
var worker = new Worker(blobURL);
worker.onmessage = function(data) {
    console.log(data.data); // gets called around 1000 times and done
};

---

编辑： 在小提琴中转载： http://jsfiddle.net/meovfpv3/1/ onmessage 回调停止触发似乎需要任意长的时间，最快几秒，最长 +5 分钟

Answer 1

这是我对正在发生的事情的最佳猜测。通过每 1 毫秒从 Web Worker 发布一条消息，您要求主线程在 1 毫秒内处理每条发布的消息。

如果主线程无法在 1 毫秒内处理消息，即使它还没有完成对最后一条消息的处理，您仍然会向它发送一条新消息。我想这会将它放入等待处理的消息队列中。

现在，由于您从 Web Worker 发送消息的速度快于处理它们的速度，因此这个未处理消息的队列将会越来越大。在某个时候，Chrome 会举手说“队列中有太多消息”，而不是将新消息排队等待处理，而是丢弃它们。

这就是为什么如果您在超时中使用一个合理的数字（例如 100 毫秒），则在发送下一条消息之前，该消息有足够的时间进行处理，并且未处理的消息不会出现问题。

---

我创建了一个 jsFiddle，worker 向主线程发送消息，主线程将消息发送回 worker。如果在发送下一条消息之前该过程没有发生，则两个线程中的计数器将不匹配，并且 Web Worker 将终止。

http://jsfiddle.net/meovfpv3/3/

您可以看到，合理的 setTimeout 为 100 毫秒，所有消息在下一条消息发生之前都有足够的时间进行处理。

当您将 setTimeout 降低到 1 毫秒时，消息链在发送下一条消息之前没有时间完成，并且每个线程中的计数器最终会变得不同步，从而触发 if 子句并终止 Web Worker。

---

解决此问题的一种方法是，不要盲目地每 1ms 发布一条消息，无论最后一条消息是否已处理，只有在收到主线程返回的消息后才发布一条新消息。这意味着您只能以主线程可以处理它们的速度发布消息。

---

为了完整起见，这里是JSFiddle code的副本：

工人：

  var counter2 = 0;
  var rcvd = true;
  function hi() {
    counter2++;
    console.log("")
    console.log("postMessage", counter2)
    postMessage(counter2);
    if (!rcvd) {
        self.close();
      console.log("No message received");
    }
    rcvd = false;
    setTimeout(hi, 1);
  }
  hi();
  onmessage = function(e) {
    rcvd = true;
    console.log("secondMessage", e.data);
  }

主要：

var ww = document.querySelector('script[type="text/ww"]'),
    code = ww.textContent,
    blob = new Blob([code], {type: 'text/javascript'}),
    blobUrl = URL.createObjectURL(blob),
    worker = new Worker(blobUrl),
    counter = 0;

worker.onmessage = function(e) {
    counter++;
  console.log("onmessage:", counter);
  worker.postMessage(e.data);
}

Answer 2

首先，我无法解释一些观察结果，但很有趣，可能对某人有启发：

• @Anson - 如果我将您的 jsFiddle 代码放入 Codepen（仍在 Chrome 中），则没有问题。 onmessage 回调一直在工作！

• 然后回到 jsFiddle... 它甚至无法将 setTimeout 更改为像 10 秒这样的长间隔，所以这不是工作人员发布消息的次数，而是 onmessage 回调之前的时间停止射击——这有很大的差异。

然后我找到了一些方法来让onmessage处理程序在这个特定的例子中保持活跃：

• 在 html 中添加一个按钮/链接和一个处理程序（我使用 jQuery），该处理程序将在单击时终止工作程序。只需添加此代码即可修复它。 $("#stop").on("click",function(e){e.preventDefault();worker.terminate();});
• 只需在定义onmessage 后添加console.log(worker)。
• 受related question 中发布的答案启发，您也可以在定义onmessage 后简单地添加window.worker = worker。

在所有情况下再次提及worker 似乎可以让它保持活力。

Answer 3

您是否尝试每 1 毫秒发布一次消息？那么你可能打算使用setInterval()：

setInterval(function(){
    postMessage('1');
}, 1);

编辑：我错误地看到了不存在的递归，只是因为我正在寻找它。我仍然会使用setInterval 而不是setTimeout。