Проблемы с реализацией async.parallel в node.io
Код, приведенный здесь, выдаст частичный вывод, а затем ошибку (self.htmlparser.parseChunk). При использовании async.series вместо async.parallel этот пример работает как положено
ping webservice будет ждать 2 секунды и затем выводить "pong", чтобы смоделировать вызов webservice
app.coffee
async = require 'async'
start = (new Date()).getTime()
require('node.io').scrape () ->
@ping = (callback, n) =>
@getHtml 'http://localhost:8888/ping', (err, $, data) =>
diff = (new Date()).getTime() - start
console.log "#{n} : #{diff}"
callback err, data
async.parallel [
(callback) =>
@ping callback, 1
,
(callback) =>
@ping callback, 2
,
(callback) =>
@ping callback, 3
,
], (err,results) =>
@exit err if err?
console.log n for n in results
@emit 'done'
Вывод с помощью async.series
1 : 2079
2 : 4089
3 : 6093
1
2
3
done
OK: Job complete
Вывод с async.parallel
3 : 2079
/home/nodeuser/src/nodews/client/node_modules/node.io/lib/node.io/request.js:296
self.htmlparser.parseChunk(chunk);
TypeError: Cannot call method 'parseChunk' of null
Sys Info
nodeuser@ubuntu:~/src/nodews/client$ node -v && coffee -v && npm -v
v0.4.12
CoffeeScript version 1.1.3
1.0.106
nodeuser@ubuntu:~/src/nodews/client$ uname -a
Linux ubuntu 2.6.38-12-generic #51-Ubuntu SMP Wed Sep 28 14:27:32 UTC 2011 x86_64 x86_64 x86_64 GNU/Linux
1 ответ
Глядя на источник node.io, кажется, что scrape
создает один Job
instance, который создает один экземпляр htmlparser, когда это необходимо, и уничтожает его при выполнении анализа (т. е. когда все данные из запроса были введены). Таким образом, вы не можете анализировать несколько источников параллельно с одного scrape
, Вместо этого используйте методы API более низкого уровня node.io (т.е. new nodeio.Job
); увидеть эту вики-страницу