Асинхронный loop без ожидания завершения обработки элемента?

Question

[Alex Wells]

Здравствуйте. Есть массив. Для каждого элемента массива нужно асинхронно, без ожидания окончания обработки вызвать event. Для этого я решил использовать AsyncEventEmitter, вот что получилось, на примере:

for(var i=0; i<20; i++) {
	events.emit('test', '...');
}
events.on('test', function(data) {
	console.log('START');
	var sl = sleep(random.integer(1000, 5000));
	sleep(sl);
	console.log('END AFTER ' + sl);
});

function sleep(milliseconds) {
	var start = new Date().getTime();
	for (var i = 0; i < 1e7; i++) {
		if ((new Date().getTime() - start) > milliseconds) break;
	}
}

К сожалению это не работает, следующий евент вызывается только после окончания предыдущего. Это меня совсем не устраивает. Причем даже если убрать эвенты, а обычный for цикл заменить async'овской библиотекой - все равно ничего. Я хоть убейся не понимаю, как заставить его вызвать сразу все эвенты одновременно. sleep() используется чисто для имитации долгой обработки, представляет собой цикл.

Answer 1

[yeti357]

Вы либо не понимаете как работает nodejs, либо не точно формулируете вопрос.
По поводу того, что у вас написано:

for(var i=0; i<20; i++) {
  events.emit('test', '...'); // при первой итерации емитится событие
}
events.on('test', function(data) {
  console.log('START');
  // если бы здесь был асинхронный вызов(обращение к бд/запрос на удалённый сервер и тд), 
  // то проблем бы не было  
  var sl = sleep(random.integer(1000, 5000)); // разобрана ниже
  sleep(sl);
  console.log('END AFTER ' + sl);
});

function sleep(milliseconds) { // функция вызываемая внутри события,
// она выполняется в основном потоке(для nodejs он один!), и соответсвенно блокирует(!) 
// поток выполнения, поэтому у вас не срабатываю остальные вызовы функции.
  var start = new Date().getTime();
  for (var i = 0; i < 1e7; i++) {
    if ((new Date().getTime() - start) > milliseconds) break;
  }
}

По комменту

Он может быть ТОЛЬКО синхронным

быть такого не может.
Но вообще посмотрите ещё на setImmidiate

Comments

[Alex Wells]

setImmidiate не помог, а чем он должен был помочь то? Все точно так-же. Хорошо, а если всередине event'а есть синхронный запрос на api? переделать его под async запрос? Все это мне очень не нравится. В C# все ограничивается Task.Run, а тут.. это вообще реально сделать? Любыми библиотеками и способами, это не важно.

[yeti357]

setImmidiate - кладёт переданную ему функцию в стэк вызова, т.е. она вызовется в одном из следующих тактов event loop-а.
Эм... как бы асинхронные функции хлеб и соль nodejs, если вы не делаете консольную утииту, то без этого никак.
Если же вам мешает асинхронный стиль написания, то добро пожаловать к промисам( https://learn.javascript.ru/promise ), генераторам ( https://learn.javascript.ru/generator ) и библиотеке co (https://www.npmjs.com/package/co ), до появления нативных async/await. Хотя вроде в 5 версии ноды, должны появиться нативные, не помню.

[Alex Wells]

yeti357: Я делаю бекенд к сайту. Много людей одновременно кидают запросы, а на каждый запрос нужно выполнить парочку запросов на сторонние АПИ. Это занимает 5-10 секунд. Но это не обычные запросы на API - этот АПИ возвращает что-то, и без этого "что-то" никак, нужно подождать ответа. По-этому я и спрашиваю.

[yeti357]

Alex_Wells: и человек и соединение реально будут ждать эти 5-10 секунд?
Опять в чём проблема то? В том что это асинхронный код? Ну добро пожаловать в javascript.
пришёл запрос -> вызвыли запрос к api -> получили ответ асинхронно -> отдали его дальше пользователю.
Не хотите использовать колбэки, используйте ивент эммиторы, промисы, генераторы. Никакого магического Task.Run нет.

[Alex Wells]

yeti357: ... а жаль.. ладно, прийдется что-то мутить :C

Answer 2

[Андрей Попов]

Вам выше уже ответили что у вас проблема только в том как конкретно вы тестируете. Я сам на этом однажды накололся.

Попробуйте сделать себе тестовый скрипт на том же PHP, который будет ждать перед ответом 1-10 секунд - в зависимости от параметра(разместите где-нибудь что бы был доступен по http). И дёргайте этот скрипт из NodeJs по http. (т.е. сэмулируете полностью свою задачу).

И увидите что будет корректно работать. Если конечно же вы будете асинхронные функции использовать для получения данных.