Node.js: дождаться выполнения двух колбеков и запустить третий

Question

[Devgru]

Мне нужно дождаться реакции на 2 асинхронных запроса (скажем, fs.readFile и fs.stat) и после того, как оба будут выполнены, вызвать некоторую функцию.
Как проще всего создать адекватный семафор для этого?

Или же порекомендуете начинать выполнение второго асинхронного запроса только по завершении первого?

Answer 1

[Анатолий]

Я себе сделал банальную очередь. Но это в клиенском жс. Мне нужно было сделать несоколько аяксовых запросов, а затем когда все закончится выполнить один результирующий (или не один) в итоге вышла такая хрень:

var queryQueue = {
	counter: 0,
	finishEvents: [],
	push: function()
	{
		queryQueue.counter ++;
	},
	pop: function()
	{
		queryQueue.counter --;
		if( queryQueue.counter === 0 )
		{
			queryQueue.fireFinish();
		}
	},
	addFinishEvent: function( func )
	{
		queryQueue.finishEvents.push( func );
		if( queryQueue.counter === 0 )
		{
			queryQueue.fireFinish();
		}
	},
	fireFinish: function()
	{
		var func = null;
		while( func = queryQueue.finishEvents.pop() )
		{
			func();
		}
	}
}

В итоге когда делаем что-то, выполняем quertQueue.push() когда действие закончилось queryQueue.pop()
после всех пушей добавляем обработчики, которые выполнятся по окончанию всех запросов (или сразу если очередь пуста).
Вариант с флагами сразу отмел, так как при изменении количества задач придется менять количество флагов.

Comments

[Devgru]

Да уж, вариант с флагами действительно негибок. Спасибо за пример.

Answer 2

[Павло Пономаренко]

Топик на Хабре: "После всех асинхронных вызовов"

Comments

[Devgru]

Интересно, удачное расширение прототипа. В целом это напоминает библиотеку Seq, эквивалентно вызову par-par-seq.
Спасибо за ссылку.

Answer 3

[Dzuba]

А банальный вариант с двумя булами не устраивает?

var firstCallFinished = false;
var secondCallFinished = false;

... вызов асинхронов ...

function firstCallback()
{
    firstCallFinished = true;
    checkFunction();
}
function secondCallback()
{
    secondCallFinished = true;
    checkFunction();
}

function checkFunction()
{
    if (!firstCallFinished || !secondCallFinished)
        return;
    firstCallFinished = false;
    secondCallFinished = false;
    ... тут вызов нужной Вам функции ...
}

Comments

[Devgru]

В принципе, похожую схему и реализовал.
Устраивает, но почему-то кажется что возможна более осмысленная схема, т.е. какой-либо объект, способный кинуть событие после того как дождался N предыдущих.

[Dzuba]

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

[Dzuba]

Вдогонку: ссылка

Answer 4

[Федор Индутный]

github.com/creationix/step

Попробуйте это библиотеку

Comments

[Devgru]

Мне кажется, Seq всё-таки лучше будет. Чуть-чуть умнее, скажем.