9

我目前正在编写一个程序，我必须处理巨大的数组。但是，我可以拆分这些数组。我现在的计划是，在不同的网络工作者中处理数组。然而，我从未与他们合作过，并且确实有几个问题：

1.如何运行多个网络工作者？我尝试了一个看起来像这样的for循环：

for(i = 0; i < eD.threads; i++){
    //start workers here 
    var worker = new Worker("js/worker/imageValues.js");
    worker.postMessage(brightness, cD.pixels[i]);
}

在这里，我确实得到了错误，即无法克隆对象。这似乎合乎逻辑。我想将它们保存在数组中会更好吗？

2.我如何控制所有人都完成了他们的工作？（我需要重新组装阵列并稍后使用它）

3.有多少网络工作者真正带来了进步？

4.除了 MDN 入口，有没有进阶教程？

谢谢！

4

2 回答 2

23

1. 如何运行多个网络工作者？我尝试了一个看起来像这样的for循环：

即使您没有在数组中跟踪它们，创建多个工人也没有问题。见下文。

2. 我如何控制所有人都完成了他们的工作？（我需要重新组装阵列并稍后使用它）

他们可以在完成后将消息发回给您，并附上结果。下面的例子。

3. 有多少网络工作者真正带来了进步？

一段绳子有多长？:-) 答案将完全取决于运行它的目标机器。现在很多人的机器上有四个或更多内核。当然，这台机器也在做很多其他的事情。您必须针对您的目标环境进行调整。

4. 除了 MDN 入口，有没有进阶教程？

网络工作者并没有太多“高级”。:-) 我发现这篇文章就足够了。

这是一个运行五个工人并观察他们完成的示例：

主窗口：

(function() {
    var n, worker, running;

    display("Starting workers...");
    running = 0;
    for (n = 0; n < 5; ++n) {
        workers = new Worker("worker.js");
        workers.onmessage = workerDone;
        workers.postMessage({id: n, count: 10000});
        ++running;
    }
    function workerDone(e) {
        --running;
        display("Worker " + e.data.id + " is done, result: " + e.data.sum);
        if (running === 0) { // <== There is no race condition here, see below
            display("All workers complete");
        }
    }
    function display(msg) {
        var p = document.createElement('p');
        p.innerHTML = String(msg);
        document.body.appendChild(p);
    }
})();

worker.js：

this.onmessage = function(e) {
    var sum, n;
    sum = 0;
    for (n = 0; n < e.data.count; ++n) {
        sum += n;
    }
    this.postMessage({id: e.data.id, sum: sum});
};

关于不存在的竞争条件：如果您考虑真正的抢占式线程，那么您可能会认为：我可以创建一个工作人员，递增running到1，然后在创建下一个工作人员之前，我可以从中获取消息第一个完成，递减running到0，并错误地认为所有工人都完成了。

这不会发生在 web worker 工作的环境中。尽管欢迎环境尽快启动 worker，并且 worker 很可能在启动 worker 的代码完成之前完成，但要做的就是排队调用到workerDone主 JavaScript 线程的函数。没有先发制人。workerDone因此我们知道在第一次调用实际执行之前，所有工作人员都已启动。因此，当runningis时0，我们知道它们都完成了。

最后说明：在上面，我onmessage = ...用来连接事件处理程序。自然地，这意味着我只能在我正在使用的对象上拥有一个事件处理程序。如果您需要有多个message事件处理程序，请使用addEventListener. 所有支持网络工作者的浏览器都支持addEventListener它们（你不必担心 IEattachEvent的事情）。

于 2013-08-12T16:32:04.490 回答
0

Stiller_leser。如果您仍然在解决问题，请查看ng-vkthread插件。它允许您实现您正在尝试在项目中开发的并行计算技术。使用此插件，您可以同时在多个线程中执行多个功能。

函数可以直接在主线程中定义，也可以从外部 javascript 文件中调用。

功能可以是：

  • 常规功能
  • 对象的方法
  • 有依赖关系的函数
  • 有上下文的函数
  • 匿名函数

基本用法：

/* function to execute in a thread */
function foo(str) {
    return str.toUpper();
}

function bar(str) {
    return str.toUpper();
}

// to execute these 2 functions in 2 threads: //

/* create objects, which you pass to vkThread as an argument*/
var param1 = {
      fn: foo,
      args: ['hello']
  };
var param2 = {
      fn: bar,
      args: ['world']
  }

/* run thread */
vkThread.execAll([param1,param2]).then(
  function (data) {
    $scope.repos = data[0] + ' ' + data[1]; // <-- HELLO WORLD
  }
);

示例和 API 文档：http ://www.eslinstructor.net/ng-vkthread/demo/

希望这可以帮助，

——瓦迪姆

于 2013-09-16T06:49:22.650 回答