Как написать неблокирующую функцию async в обработчике запросов Express

Все:

Я новичок в асинхронном программировании Node, интересно, как я могу написать обработчик запросов Express, который может обрабатывать трудоемкую тяжелую задачу вычисления без блока Express обрабатывая следующий запрос?

Я думал, что setTimeout может сделать это, чтобы помещать задание в цикл событий, но он по-прежнему блокирует другие запросы:

var express = require('express');
var router = express.Router();


function heavy(callback){
    setTimeout(callback, 1);
}

router.get('/', function(req, res, next) {
    var callback = function(req, res){
        var loop = +req.query.loop;
        for(var i=0; i<loop; i++){
            for(var j=0; j<loop; j++){}
        }
        res.send("finished task: "+Date.now());
    }.bind(null, req, res);

    heavy(callback)
});

Я думаю, я не понимал, как работает setTimeout (мое понимание о setTimeout после этой задержки 1 мс приведет к обратному вызову в отдельном потоке/процессе, не блокируя другой вызов тяжелой), может ли кто-нибудь показать мне, как это сделать это без блокировки другого запроса на heavy()?

Спасибо

Ответы

Ответ 1

Вместо setTimeout лучше использовать process.nextTick или setImmediate (в зависимости от того, когда вы хотите, чтобы ваш обратный вызов выполнялся). Но недостаточно добавить длинный код в функцию, потому что он по-прежнему будет блокировать поток, только через миллисекунду позже.

Вам нужно разбить свой код и запустить setImmediate или process.nextTick несколько раз - как на каждой итерации, а затем назначить новую итерацию. В противном случае вы ничего не выиграете.

Пример

Вместо этого кода:

var a = 0, b = 10000000;

function numbers() {
  while (a < b) {
    console.log("Number " + a++);
  }
}

numbers();

вы можете использовать такой код:

var a = 0, b = 10000000;

function numbers() {
  var i = 0;
  while (a < b && i++ < 100) {
    console.log("Number " + a++);
  }
  if (a < b) setImmediate(numbers);
}

numbers();

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

Вы также можете рассмотреть возможность нереста внешнего процесса или записи собственного добавления в C/С++, где вы можете использовать потоки.

Подробнее см.: