如何在无限循环中中断puppeteer-cluster的执行？

const { Cluster } = require('puppeteer-cluster');
const { sleep } = require('sleep');

async function runCluster() {
  const cluster = await Cluster.launch({
    concurrency: Cluster.CONCURRENCY_CONTEXT,
    maxConcurrency: 2, // 设置最大并发数
    puppeteerOptions: { headless: true }, // 设置puppeteer选项
  });

  // 定义任务处理函数
  await cluster.task(async ({ page, data }) => {
    // 在这里执行你的任务逻辑
    await page.goto(data.url);
    // ...
  });

  // 添加任务到队列
  cluster.queue({ url: 'https://example.com' });
  cluster.queue({ url: 'https://example.net' });

  // 无限循环
  while (true) {
    // 检查是否需要中断执行
    if (shouldInterrupt()) {
      break;
    }

    // 等待一段时间
    sleep(1000);
  }

  // 关闭cluster
  await cluster.close();
}

runCluster().catch(console.error);