2

我正在开发一个在 Web 浏览器中运行的 Javascript 模拟器。它有一个主循环：

do {
    updateVisualization(simulator);
    simulator.doStep();
} while (!reachedGoal(simulator));

对于每次迭代，我都需要运行几个必须同时执行的工作人员：

doStep = function() {
    ...
    for (every agent in the simulation) {
        var worker = new Worker('worker.js');
        worker.onmessage = function(event) {
            ...
        }
        worker.postMessage(...);
    }

    // Here is the problem
}

我的问题是：我怎么能等待每个工人完成？

4

1 回答 1

4

一条建议：

doStep = function () {
    var i, worker;

    updateVisualization( simulator );    

    simulator.workers = []; // array of workers for this step

    for ( i = 0; i < agents.length; i++ ) {
        // set up new worker
        worker = new Worker( 'worker.js' );
        worker.onmessage = function ( e ) {
            var i;

            if ( e.data === 'finished' ) {
                this.finished = true;

                for ( i = 0; i < simulator.workers.length; i++ ) {
                    if ( !simulator.workers[i].finished ) {
                        return;
                    }
                }

                // survived for-loop = all workers finished
                if ( !reachedGoal( simulator ) ) { // another iteration?
                    simulator.doStep();    
                }
            }
        };
        worker.postMessage( 'doStep' );

        simulator.workers.push( worker ); // push worker into workers array
    }
};

所以所有的动作都发生在onmessage工人的回调中。每次工作人员用消息响应时，您通过检查是否所有工作人员都将属性设置为来检查simulator.workers数组。如果是这种情况，这意味着所有工作人员都完成了，您可以继续前进（“幸存的 for 循环”部分）。finishedtrue

所以基本上，您实例化所有工作人员，然后等待他们的响应......不需要循环。

于 2011-09-09T15:30:12.533 回答