Promise based queue

Question

У меня есть массив files, что я хотел бы атаковать N за раз. И функция doWork, которая возвращает обещание.

var files = [] 

var doWork = function(file) { 
    return asyncFn(file) 
} 

Я бы хотел,

Редактировать: Я пробовал различные модули (prom-queue, async-q). Все они работают в моде, но они не позволяют использовать массив в качестве очереди. У них есть собственная внутренняя структура, на которую нужно надавить.

Причина, по которой мне нужно использовать массив, поскольку я хочу, чтобы он мог вставить элемент в очередь, и убедитесь, что он еще не находится в очереди.

Answer 1

Вот как вы это сделаете с Bluebird, который вы указали, что используете.

var files = ["foo.txt", "bar.txt", "baz.txt"]; 
var task = Promise.map(files, doWork, {concurrency: 4}); // four at a time 

task.then(function(results){ 
     // results contains the results, tasks are executed at most 4 at a time 
}); 

Слово предостережения - это ставит верхний предел на сколько текущий вызов будет работать, вызывая функцию несколько раз, или из нескольких процессов узлов будет (очевидно) выполняют с большей/меньшей параллелизм. Однако в простом случае - это работает.

Answer 2

Вы могли бы сделать что-то вроде этого:

function enq (step) 
    var f = function() { 
    var d = Q.defer(); 
    step(d); 
    return d.promise; 
    } 
    enq_head = enq_head.then(f); 
} 

где шаг является функция, которая выполняет обещание вам передать его. Но я не рекомендую это, потому что это просто причудливый способ сделать то, что setTimeout делает намного эффективнее.

Если вы хотите отслеживать, какие файлы были запланированы и/или завершены, просто поместите их в готовый список или выньте их из списка задач, из которого вы их получите, вставьте bool в объект под имя файла или что-то еще. Это отдельная проблема из планирования.