Как писать асинхронные функции для Node.js

Я попытался выяснить, как именно следует писать асинхронные функции. После долгого изучения большого количества документации мне все еще неясно.

Как мне написать асинхронные функции для Node? Как правильно реализовать обработку событий ошибок?

Другой способ задать свой вопрос: как мне интерпретировать следующую функцию?

var async_function = function(val, callback){
    process.nextTick(function(){
        callback(val);
    });
};

Кроме того, мне показался интересным этот вопрос о SO («Как мне создать неблокирующую асинхронную функцию в node.js?»). Мне кажется, что на него еще нет ответа.

Кажется, вы путаете асинхронный ввод-вывод с асинхронными функциями. node.js использует асинхронный неблокирующий ввод-вывод, потому что неблокирующий ввод-вывод лучше. Лучший способ понять это - пойти посмотреть несколько видео Райана Даля.

Как мне написать асинхронные функции для Node?

Просто напишите обычные функции, с той лишь разницей, что они не выполняются сразу, а передаются как обратные вызовы.

Как мне правильно реализовать обработку событий ошибок

Обычно API дает обратный вызов с ошибкой в ​​качестве первого аргумента. Например

database.query('something', function(err, result) {
  if (err) handle(err);
  doSomething(result);
});

Это общий образец.

Другой распространенный паттерн: on('error') . Например

process.on('uncaughtException', function (err) {
  console.log('Caught exception: ' + err);
});

Редактировать:

var async_function = function(val, callback){
    process.nextTick(function(){
        callback(val);
    });
};

Вышеупомянутая функция при вызове как

async_function(42, function(val) {
  console.log(val)
});
console.log(43);

Будет печатать 42на консоль асинхронно. В частностиprocess.nextTick срабатывает после того, как текущий стек вызовов eventloop пуст. Этот стек вызовов пуст после выполнения async_functionи console.log(43)выполнения. Итак, мы печатаем 43, а затем 42.

Вам, вероятно, следует почитать цикл событий.

Недостаточно просто пропустить обратные вызовы. Например, вы должны использовать settimer, чтобы сделать функцию асинхронной.

Примеры: Не асинхронные функции:

function a() {
  var a = 0;    
  for(i=0; i<10000000; i++) {
    a++;
  };
  b();
};

function b() {
  var a = 0;    
  for(i=0; i<10000000; i++) {
    a++;
  };    
  c();
};

function c() {
  for(i=0; i<10000000; i++) {
  };
  console.log("async finished!");
};

a();
console.log("This should be good");

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

Псевдопоточные (асинхронные) функции:

function a() {
  setTimeout ( function() {
    var a = 0;  
    for(i=0; i<10000000; i++) {
      a++;
    };
    b();
  }, 0);
};

function b() {
  setTimeout ( function() {
    var a = 0;  
    for(i=0; i<10000000; i++) {
      a++;
    };  
    c();
  }, 0);
};

function c() {
  setTimeout ( function() {
    for(i=0; i<10000000; i++) {
    };
    console.log("async finished!");
  }, 0);
};

a();
console.log("This should be good");

Этот будет действительно асинхронным. Это должно быть хорошо, будет написано до завершения async.

Вы должны посмотреть это: Node Tuts, серия 19 - Шаблоны асинхронных итераций

Он должен ответить на ваши вопросы.

Если вы ЗНАЕТЕ, что функция возвращает обещание, я предлагаю использовать новые функции async / await в JavaScript. Благодаря этому синтаксис выглядит синхронным, но работает асинхронно. Когда вы добавляете asyncключевое слово в функцию, оно позволяет вам выполнять awaitобещания в этой области:

async function ace() {
  var r = await new Promise((resolve, reject) => {
    resolve(true)
  });

  console.log(r); // true
}

Если функция не возвращает обещание, я рекомендую заключить его в новое обещание, которое вы определяете, а затем разрешите данные, которые вы хотите:

function ajax_call(url, method) {
  return new Promise((resolve, reject) => {
    fetch(url, { method })
    .then(resp => resp.json())
    .then(json => { resolve(json); })
  });
}

async function your_function() {
  var json = await ajax_call('www.api-example.com/some_data', 'GET');
  console.log(json); // { status: 200, data: ... }
}

Итог: используйте мощь обещаний.

Попробуйте это, это работает как для узла, так и для браузера.

isNode = (typeof exports !== 'undefined') &&
(typeof module !== 'undefined') &&
(typeof module.exports !== 'undefined') &&
(typeof navigator === 'undefined' || typeof navigator.appName === 'undefined') ? true : false,
asyncIt = (isNode ? function (func) {
  process.nextTick(function () {
    func();
  });
} : function (func) {
  setTimeout(func, 5);
});

Я потратил слишком много часов на такую ​​задачу для node.js. Я в основном фронтенд-парень.

Я считаю это очень важным, потому что все асинхронные методы узла имеют дело с обратным вызовом, и преобразование его в Promise лучше справляется с этим.

Я просто хочу показать возможный результат, более компактный и читаемый. Используя ECMA-6 с async, вы можете написать это так.

 async function getNameFiles (dirname) {
  return new Promise((resolve, reject) => {
    fs.readdir(dirname, (err, filenames) => {
      err !== (undefined || null) ? reject(err) : resolve(filenames)
    })
  })
}

(undefined || null)для Repl (чтение событий цикла печати) сценариев, используя неопределенные также работу.