Break 用于事件循环处理而不中断循环

Question

我发现自己最近试图处理大量数据，我不得不做一些（我们称之为）创造性编码来获得所需的结果。

我知道处理将是一个多天的任务，所以我以一种可以中断和恢复的方式编写它。但让我难过的是找到一种处理 SIGINT/SIGTERM 样式事件的好方法，而不想破坏我的循环。

顺便说一句这些显然不是我的函数的真实名称

let closed = false;
function* syncGenerator() {
  yield* ~20-trillion-calculated-results;
}
function main() {
  try {
    for ( const value of syncGenerator() ) {
      syncWork(value);
      if (closed) {
        syncGracefulCleanup();
        break;
      }
    }
  } catch ( err ) {
    handleError(err);
  } finally {
    syncGracefulCleanup2();
  }
}
process.on('SIGINT', () => closed = true);

我没有意识到当我还在 for 循环中时，SIGINT 永远不会被处理，因此只会在整个数据集被处理后才能完成（一个非常愚蠢的疏忽，我想我误以为它会工作与 Arduino 硬件中断相同。D'oh。经验教训。

现在我意识到了这一点，我的解决方案是使用微任务异步等待技巧将我的一半代码放在滴答声的末尾。

let closed = false;
function* syncGenerator() {
  yield* ~20-trillion-calculated-results;
}
async function main() {
  try {
    for ( const value of syncGenerator() ) {
      syncWork(value);
      await new Promise(r => setImmediate(r)); // the new nasty
      if (closed) {
        syncGracefulCleanup();
        break;
      }
    }
  } catch ( err ) {
    handleError(err);
  } finally {
    syncGracefulCleanup2();
  }
}
process.on('SIGINT', () => closed = true);

现在，这可以按我的预期工作，并且 await 允许暂停循环并允许处理 SIGINT/SIGTERM，然后在 close 设置为 true 时继续。耶.. 但是该死的，它看起来很讨厌。 我希望有人可能有比这更好看的解决方案？

Answer 1

你需要保留标志，但你可以让你的主要逻辑更简单。考虑

let closed = false;
function* syncGenerator() {
  yield* ~20-trillion-calculated-results;
}

function main( generator = syncGenerator() ) 
{
    if (closed) 
    {
      syncGracefulCleanup();
    }
    else 
    {
        // assuming syncWork returns false when 
        // there are no more value
        if ( syncWork( generator.next() ) )
        {
            // next-ish off to the event loop. this is NOT recursive, 
            // even though it may look a bit like it
            setTimeout( () => main(generator), 0 );         
        }
    }
}

process.on('SIGINT', () => close = true);