时间戳

首页 > 解决方案 > 如何使用超时中断/取消异步内部的 forEach 循环

node.js - 如何使用超时中断/取消异步内部的 forEach 循环

问题描述

我有一个像 [1,2,3,4,5,6,7,8,9,10] 这样的数组。我想运行这个数组的 forEach，每个项目都有超时 1s，如果当前项目符合条件，则中断 foreach。我发现仅适用于异步的代码：

var BreakException = {};

try {
  [1,2,3,4,5,6,7,8,9,10].forEach(function(el) {
    console.log(el);
    if (el === 6) throw BreakException;
  });
} catch (e) {
  if (e !== BreakException) throw e;
}

但是当我使用异步时，它会运行所有项目：

var BreakException = {};
let list = [1, 2, 3, 4, 5, 6, 7, 8, 9, 10];
var realtimePromise = new Promise((resolve, reject) => {
  list.every(async(item, pKey) => {
    await setTimeout(function() {
      try {
        console.log(item);
        if (item === 6) throw BreakException;
      } catch (e) {
        if (e !== BreakException) throw e;
      }
    }, 2000 * pKey);
  });
});
realtimePromise.then(() => {
  console.log('------- End loop -------');
});

有人有这个问题的解决方案吗？

标签： node.jsasynchronouspromise

解决方案

使用这样的递归函数会更好，因为退出forEach带有错误的循环不是一个好习惯：

const list = [1, 2, 3, 4, 5, 6, 7, 8, 9, 10];

const realtimePromise = (index = 0) => {
    return new Promise((resolve, reject) => {
        if (index > list.length - 1) reject(new Error('Item not in list'));
        const currentItem = list[index];
        console.log(currentItem);
        if (currentItem === 6) resolve(currentItem);
        else setTimeout(() => {
            resolve(realtimePromise(++index));
        }, 2000);
    });
}

realtimePromise().then(() => {
    console.log('------- End loop -------');
});

推荐阅读