Wie Generatorfunktionen parallel ausgeführt werden?

Question

Angenommen, ich habe einen Koa Webserver mit einem Endpunkt wie folgt aus:

const perform = require(...); // some generator function 

exports.endpoint = function*() { 

    var results = yield getResults(); 

    // Respond the results 
    this.body = results; 
} 

exports.getResults = function*() { 

    var actions = [...]; 
    var results = []; 

    for (var action of actions) { 

     var result = yield perform(action); 

     results.push(results); 
    } 

    return results; 
} 

Nun wird der Kunde die erhalten reagieren, nachdem alle Aktionen offensichtlich durchgeführt werden. aber die Dinge sind jede Handlung hängt von der Vollendung der vorherigen ab.

Gibt es eine Möglichkeit, sie parallel auszuführen?

Hinweis: Sie zu Promises zu schalten ist keine Option, es sei denn, ich kann die Ergebnisse irgendwie zurückgeben und sie nicht auflösen().

Answer 1

co schalten die Generatorfunktion zu Promises, und führt sie async. Promise.all wartet auf alle von ihnen zu beenden:

exports.getResults = function*() { 

    var actions = [...]; 

    return yield Promise.all(actions.map(function(action) { 
     return co(function*() { 
      return yield perform(action); 
     } 
    })); 
} 

Answer 2

Wenn die Generatoren als Koroutinen verwendet werden, durch die async/await Strömung simulieren, dann sollten Sie in der Lage zu tun:

var results = yield Promise.all(actions.map(action => perform(action))); 

oder sogar:

var results = yield Promise.all(actions.map(perform)); 

Ich bin nicht sicher über die genaue Verwendung hier, aber wenn Sie Generatoren mit co oder Bluebird.coroutine dann verwenden Sie bereits Versprechungen, so können Sie sie auch expliziter verwenden.

Anstatt also:

exports.getResults = function*() { 

    var actions = [...]; 
    var results = []; 

    for (var action of actions) { 

     var result = yield perform(action); 

     results.push(results); 
    } 

    return results; 
} 

können Sie versuchen:

exports.getResults = function*() { 

    var actions = [...]; 

    return yield Promise.all(actions.map(perform)); 
}