Tag: asynchronous

Node.js Api在Async循环中调用

我很难做出多个API调用，并得到正确的地方返回的结果。 这是我想要实现的：两个循环，嵌套。 外层循环遍历复杂的json对象，并将一些对象的值放入数组调用框中。 内部循环调用api，并将返回的结果放入一个名为bag的数组中。 所以我有箱子和袋子充满数据。 当循环和API呼叫都结束时，我想要访问箱子和包里的数据，然后用它做东西。 我只是不确定最好的方法去同时访问两个数组。 这是我到目前为止，但袋和框当然是空的，因为它们在所有循环和API调用结束之前被调用。 var data = {}//a json object with data; var bag = []; var box = []; async.forEach(data.item, function(item, callback){ async.forEach(item.name, function(name, callback){ callApi(item.name, function(obj){ bag.push(obj); }); callback(); } box.push(item); callback(); }); function callApi(name, callback){ asyncApiCall(url+name, function(err, result){ callback(result); }); } //when all loops and api requests are […]

如何在第一次失败后停止async.queue？

我想在发生第一个任务错误后停止执行我的async.queue。 我需要在并发限制的同时执行几个类似的操作，但是在第一个错误之后停止所有的操作。 我该怎么做，或者我应该使用什么？

nodejsasynchronous嵌套调用

我想要废除一个url： 1请求获取元素列表 1请求每个结果得到细节 这里我有什么： var request = require('request') , cheerio = require('cheerio') , async = require('async') , format = require('util').format; var baseurl = 'http://magiccards.info'; async.waterfall([ function (callback) { request(baseurl + '/sitemap.html', function (err, response, body) { var sets = []; var $ = cheerio.load(body); $('a[href$="/en.html"]').each(function () { sets.push({"name": $(this).text(), "code":$(this).attr('href').match(/\/([^)]+)\//)[1], "path": $(this).attr('href'), "translations":[]}); }); callback(null, […]

asynchronousIO服务器：精简（Ruby）和Node.js. 有什么区别？

我想澄清我的asynchronousIO的概念，非阻塞服务器在处理Node.js时，很容易在概念之下 var express = require('express'); var app = express(); app.get('/test', function(req, res){ setTimeout(function(){ console.log("sleep doesn't block, and now return"); res.send('success'); }, 2000); }); var server = app.listen(3000, function() { console.log('Listening on port %d', server.address().port); }); 我知道，当node.js等待setTimeout 2秒时，它可以同时处理另一个请求，一旦2秒过去，它就会调用它的callback函数。 在Ruby世界，瘦服务器呢？ require 'sinatra' require 'thin' set :server, %w[thin] get '/test' do sleep 2 <—- "success" end 上面的代码片段使用瘦服务器（非阻塞，asynchronousIO），当与asynchronousIO交谈时，我想询问何时到达sleep 2 […]

无法在Node.js循环中设置超时

在这里，我试图设置每个迭代超时，但我不能让它因为nodejs的性质。 有没有办法做到这一点？ 提前致谢 for (var i = 1; i <= 1000; i++) { setTimeout(function () { console.log('something') }, 3000); }

在Node.js中asynchronous添加到数组中

我对这种types的编程非常新，我从嵌套调用中填充数组时遇到了一些麻烦。 我很确定这需要使用callback来完成，但是我无法绕过它的大脑。 closures也必须在这里发挥作用。 我试图在网上search一个类似的例子，但没有发现太多。 这是我的原始代码。 我尝试了一些不同的方法，但没有把它closures。 TaskSchema.statics.formatAssignee = function(assignees) { var users = []; assignees.forEach(function(uid) { mongoose.model('User').findById(uid, function(err, user) { users.push({ name: user.name.full , id: user.id }); }); }); return users; }

Nodejsasynchronous混乱

我似乎无法理解如何保持与NodeJs的asynchronous控制stream。 所有的嵌套使得我的代码很难阅读。 我是新手，所以我可能错过了大局。 简单地编码这样的东西有什么错 function first() { var object = { aProperty: 'stuff', anArray: ['html', 'html']; }; second(object); } function second(object) { for (var i = 0; i < object.anArray.length; i++) { third(object.anArray[i]); }; } function third(html) { // Parse html } first();

asynchronous – 传递variables和保存上下文

如果您有以下代码： var asyncConfig = {}; var a, b; for(var i = 0; i < someValue; i++) { // do something with a // do something with b asyncConfig[i] = function(callback) { func(a, b, callback); // func is async } } // Include some more parallel or series functions to asyncConfig async.auto(asyncConfig); 如何将variablesa和b的值传递给func以便在for循环之后执行async.auto(asyncConfig)时，保留a和b的上下文？ （每次执行func a和b不同上下文） 先谢谢你 […]

JS：async.each的等价承诺是什么？

似乎今天宣布，承诺将在ES6。 我从来没有成为一个承诺的家伙，.then（）的史诗链似乎比async.waterfall（）中的一个简单的函数列表更复杂，但是看起来像我将不得不去学习它们。 那么，其他非常stream行的工作streamasync.each（）是什么呢？ async.each(items, processItem, function(err){ doSomething(err) }); 例如，在每个项目上运行processItem函数，一旦完成，继续执行doSomething（如果任何processItem（）被搞砸，则执行一些不同的操作）。 我如何在承诺中做到这一点？ 是否有一个官方的承诺用户文档的地方（不是诺言规范 ，实际示例工作stream程，以及如何做承诺）像asynchronous呢？

JavaScript同步循环

当我的testing数据扩展到生产工作时，我一直在关注JavaScript的asynchronous行为。 我有一个for循环，我知道将在成千上万的范围内，节点暂停一个for循环，并回到它，或者我可以安全地假设节点将返回我的函数之前执行循环完成？ 这是问题的循环： function fixData(dataset, blockcount){ for (var i = 0, len = dataset.length; i < len; i++) { var obj = dataset[i]; obj._id = obj.name; obj.expires = blockcount + obj.expires_in; delete obj.expires_in; } return dataset; }