Как создать неблокирующую асинхронную функцию в node.js?

Question

Как создать неблокирующую асинхронную функцию? Ниже то, что я пытаюсь достичь, но моя программа по-прежнему блокирует ...

var sys = require("sys"); 

function doSomething() { 
    sys.puts("why does this block?"); 
    while(true); 
} 

setTimeout(doSomething,0); 
setTimeout(doSomething,0); 
setTimeout(doSomething,0); 

sys.puts("main"); 

Answer 1

setTimeout не будет создавать новую тему, так что браузер будет еще висеть в бесконечном цикле.

Вам необходимо переосмыслить структуру вашей программы.

Answer 2

Вам необходимо запустить функцию блокировки в отдельном процессе.

Этот модуль может помочь: http://github.com/cramforce/node-worker

Answer 3

Эта строка:

while(true); 

не "блокирует", это просто занят, навсегда.

Answer 4

Если вы не хотите использовать WebWorker API/node-worker, который по-прежнему очень альфа, просто создайте дополнительную программу узла и обменивайтесь данными через TCP или HTTP.

Это позволяет отправлять вашу работу в виде HTTP-вызовов или необработанных данных TCP и асинхронно ждать ответа HTTP-ответа/входящего TCP-ответа.

Обратите внимание, что это подходит только в том случае, если ваша задача легко сериализуема.

Answer 5

Асинхронный ввод-вывод в node.js можно выполнять только с помощью асинхронных функций ввода-вывода, предоставляемых версиями node.js runtime или node.js, написанными на C++. Ваш собственный Javascript-код всегда синхронен в node.js. Асинхронный не-IO-код редко необходим, а дизайнеры node.js решили вообще его избегать.

Есть несколько загадочных способов запуска Javascript асинхронно в node.js, упомянутых другими комментаторами, но node.js не предназначен для такого типа работы. Используйте Erlang, если вам нужен такой тип параллелизма, node.js - это только паралогл IO, а для параллельных вычислений он так же плох, как Python или PHP.

Answer 6

Перекресток с Reddit.

---

Цель асинхронных функций в JavaScript немного отличается от того, что вы ищете.

Помните, что JavaScript однопоточный - он может делать только одну вещь за раз. Вот некоторые традиционные, блокирующие код:

sys.puts("Before"); 
sleep(10); 
sys.puts("After"); 

В веб-приложение в реальном мире, то sleep() вместо этого может быть трудоемким вызов базы данных, запрос сети (например, ожидание данных из веб-браузера пользователя), помощник инструмента или доступа к файлам.

Если вы использовали блокирующие вызовы, подобные описанному выше, сервер Node.js не сможет ничего сделать (например, начать обрабатывать другие веб-запросы) во время ожидания.

PHP и многие другие среды веб-программирования справляются с этим, создавая полностью отдельные потоки для каждого запроса. Node.js использует функции обратного вызова.Вы могли бы написать один и тот же код, как это, вместо того, чтобы:

sys.puts("Before"); 
setTimeout(function(){ 
    sys.puts("After"); 
}, 10000); 

Здесь вы создаете функцию и передать его в setTimeout(). Его код еще не запущен, но когда он это сделает, он будет иметь доступ ко всей области (все переменные), где она была создана. setTimeout() получает ссылку на функцию и расписывает событие, которое должно срабатывать по the event loop после истечения таймаута.

Цикл событий, по сути, представляет собой список дел программы Node.js (они распространены - все приложения GUI, запущенные на вашем компьютере, возможно, используют циклы событий!).

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

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

Редко вам нужно делать блокирующие работы внутри вашей программы Node.js. Если вы это сделаете, вы должны разделить эту работу на отдельный процесс (который может даже быть другой программой Node.js) или написать a C/C++ addon, который может свободно использовать потоки.

Answer 7

Вы можете сделать это без использования дочернего процесса с использованием nextTick()

я просто читал это объяснение другой день о nextTick ... это великий читать IMO

http://howtonode.org/understanding-process-next-tick

Answer 8

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

process.nextTick: эта функция может быть сложена, что означает, что если она называется рекурсивно, она будет l (process.maxTickDepth) количество раз за галочку цикла события.

или

setImmediate: эта функция гораздо ближе к установке 0 тайма-аута (но бывает и раньше).

В большинстве случаев вам следует выбрать setImmediate.

Answer 9

Я предполагаю, что вы экспериментируете с Nodejs, также я предполагаю, что вы не пишете сам модуль npm и не экспортируете свою функцию в качестве асинхронной функции. На практике вы не столкнетесь с таким случаем, если вы хотите выполнять какие-либо операции блокировки в функциях или в обратных вызовах, которые выполняются в среде с одним потоком, попробуйте использовать соответствующие модули узлов, такие как fs для чтения файлов, запрос на сетевой запрос и асинхронный модуль, который предоставляет различные типы операций async, также помните, что вы пытаетесь выполнить cpu, потребляющий код асинхронно, это плохая идея, потому что 2HZ может выполнять миллион строк кода всего за минус микросекунды

Основная цель nodejs - решить проблему, которую вы задали в вопросе, который является обработанный базовым libuv для обработки асинхронных событий, я ценю ответ на использование установленного тайм-аута, но вы не знаете, сколько времени ждать или использовать работу с узлом, это прекрасно, но вы в конечном итоге напишите много кода плиты котла, поэтому просто найдите модуль npm, который удовлетворит ваши потребности.