正如标题所示。我该怎么做呢？
我想whenAllDone()在 forEach 循环遍历每个元素并完成一些异步处理之后调用。
[1, 2, 3].forEach(
function(item, index, array, done) {
asyncFunction(item, function itemDone() {
console.log(item + " done");
done();
});
}, function allDone() {
console.log("All done");
whenAllDone();
}
);
有可能让它像这样工作吗？当 forEach 的第二个参数是一个回调函数时，它会在经过所有迭代后运行？
预期输出：
3 done
1 done
2 done
All done!
Array.forEach不提供这种精细（哦，如果可以的话），但有几种方法可以完成你想要的：
function callback () { console.log('all done'); }
var itemsProcessed = 0;
[1, 2, 3].forEach((item, index, array) => {
asyncFunction(item, () => {
itemsProcessed++;
if(itemsProcessed === array.length) {
callback();
}
});
});
（感谢@vanuan 和其他人）这种方法保证在调用“完成”回调之前处理所有项目。您需要使用在回调中更新的计数器。取决于索引参数的值不提供相同的保证，因为异步操作的返回顺序是不保证的。
（promise 库可用于旧版浏览器）：
处理所有保证同步执行的请求（例如 1 然后 2 然后 3）
function asyncFunction (item, cb) {
setTimeout(() => {
console.log('done with', item);
cb();
}, 100);
}
let requests = [1, 2, 3].reduce((promiseChain, item) => {
return promiseChain.then(() => new Promise((resolve) => {
asyncFunction(item, resolve);
}));
}, Promise.resolve());
requests.then(() => console.log('done'))
在没有“同步”执行的情况下处理所有异步请求（2 可能比 1 更快地完成）
let requests = [1,2,3].map((item) => {
return new Promise((resolve) => {
asyncFunction(item, resolve);
});
})
Promise.all(requests).then(() => console.log('done'));
还有其他异步库，其中async是最流行的，它们提供了表达你想要的东西的机制。
编辑问题的主体已被编辑以删除先前同步的示例代码，因此我更新了我的答案以澄清。原始示例使用类似同步的代码来模拟异步行为，因此应用了以下内容：
array.forEach是同步的res.write，所以你可以简单地将你的回调放在你调用 foreach 之后：
posts.foreach(function(v, i) {
res.write(v + ". index " + i);
});
res.end();
如果您遇到异步函数，并且您想确保在执行代码之前完成其任务，我们总是可以使用回调功能。
例如：
var ctr = 0;
posts.forEach(function(element, index, array){
asynchronous(function(data){
ctr++;
if (ctr === array.length) {
functionAfterForEach();
}
})
});
注意：functionAfterForEach是foreach任务完成后要执行的函数。 asynchronous是foreach内部执行的异步函数。
奇怪的是异步案例有多少错误的答案！可以简单地表明检查索引没有提供预期的行为：
// INCORRECT
var list = [4000, 2000];
list.forEach(function(l, index) {
console.log(l + ' started ...');
setTimeout(function() {
console.log(index + ': ' + l);
}, l);
});
输出：
4000 started
2000 started
1: 2000
0: 4000
如果我们检查index === array.length - 1，回调将在第一次迭代完成时调用，而第一个元素仍在等待中！
要在不使用诸如异步之类的外部库的情况下解决此问题，我认为最好的选择是保存列表的长度并在每次迭代后递减。由于只有一个线程，我们确信没有竞争条件的机会。
var list = [4000, 2000];
var counter = list.length;
list.forEach(function(l, index) {
console.log(l + ' started ...');
setTimeout(function() {
console.log(index + ': ' + l);
counter -= 1;
if ( counter === 0)
// call your callback here
}, l);
});
希望这能解决您的问题，当我需要执行 forEach 内部的异步任务时，我通常会使用它。
foo = [a,b,c,d];
waiting = foo.length;
foo.forEach(function(entry){
doAsynchronousFunction(entry,finish) //call finish after each entry
}
function finish(){
waiting--;
if (waiting==0) {
//do your Job intended to be done after forEach is completed
}
}
和
function doAsynchronousFunction(entry,callback){
//asynchronousjob with entry
callback();
}
使用 ES2018，您可以使用异步迭代器：
const asyncFunction = a => fetch(a);
const itemDone = a => console.log(a);
async function example() {
const arrayOfFetchPromises = [1, 2, 3].map(asyncFunction);
for await (const item of arrayOfFetchPromises) {
itemDone(item);
}
console.log('All done');
}
我没有 Promise 的解决方案（这可以确保每个动作在下一个动作开始之前结束）：
Array.prototype.forEachAsync = function (callback, end) {
var self = this;
function task(index) {
var x = self[index];
if (index >= self.length) {
end()
}
else {
callback(self[index], index, self, function () {
task(index + 1);
});
}
}
task(0);
};
var i = 0;
var myArray = Array.apply(null, Array(10)).map(function(item) { return i++; });
console.log(JSON.stringify(myArray));
myArray.forEachAsync(function(item, index, arr, next){
setTimeout(function(){
$(".toto").append("<div>item index " + item + " done</div>");
console.log("action " + item + " done");
next();
}, 300);
}, function(){
$(".toto").append("<div>ALL ACTIONS ARE DONE</div>");
console.log("ALL ACTIONS ARE DONE");
});<script src="https://ajax.googleapis.com/ajax/libs/jquery/2.1.1/jquery.min.js"></script>
<div class="toto">
</div> var counter = 0;
var listArray = [0, 1, 2, 3, 4];
function callBack() {
if (listArray.length === counter) {
console.log('All Done')
}
};
listArray.forEach(function(element){
console.log(element);
counter = counter + 1;
callBack();
});
var i=0;
const waitFor = (ms) =>
{
new Promise((r) =>
{
setTimeout(function () {
console.log('timeout completed: ',ms,' : ',i);
i++;
if(i==data.length){
console.log('Done')
}
}, ms);
})
}
var data=[1000, 200, 500];
data.forEach((num) => {
waitFor(num)
})
我尝试了简单的方法来解决它，与您分享：
let counter = 0;
arr.forEach(async (item, index) => {
await request.query(item, (err, recordset) => {
if (err) console.log(err);
//do Somthings
counter++;
if(counter == tableCmd.length){
sql.close();
callback();
}
});
request是 Node js 中 mssql 库的函数。这可以替换您想要的每个功能或代码。祝你好运
我的解决方案：
//Object forEachDone
Object.defineProperty(Array.prototype, "forEachDone", {
enumerable: false,
value: function(task, cb){
var counter = 0;
this.forEach(function(item, index, array){
task(item, index, array);
if(array.length === ++counter){
if(cb) cb();
}
});
}
});
//Array forEachDone
Object.defineProperty(Object.prototype, "forEachDone", {
enumerable: false,
value: function(task, cb){
var obj = this;
var counter = 0;
Object.keys(obj).forEach(function(key, index, array){
task(obj[key], key, obj);
if(array.length === ++counter){
if(cb) cb();
}
});
}
});
例子：
var arr = ['a', 'b', 'c'];
arr.forEachDone(function(item){
console.log(item);
}, function(){
console.log('done');
});
// out: a b c done
在这个问题上有很多解决方案和方法可以实现这一目标！
但是，如果您需要使用map和async/await来执行此操作，那么就在这里
// Execution Starts
console.log("start")
// The Map will return promises
// the Execution will not go forward until all the promises are resolved.
await Promise.all(
[1, 2, 3].map( async (item) => {
await asyncFunction(item)
})
)
// Will only run after all the items have resolved the asynchronous function.
console.log("End")
输出将是这样的！可能因异步功能而异。
start
2
3
1
end
注意：如果你在地图中使用await，它总是会返回 promises 数组。
setInterval 怎么样，检查完整的迭代计数，带来保证。不确定它是否不会使范围超载，但我使用它并且似乎是一个
_.forEach(actual_JSON, function (key, value) {
// run any action and push with each iteration
array.push(response.id)
});
setInterval(function(){
if(array.length > 300) {
callback()
}
}, 100);
您不需要回调来遍历列表。只需end()在循环之后添加调用。
posts.forEach(function(v, i){
res.write(v + ". Index " + i);
});
res.end();