JavaScript异步任务编排：实现带延迟的数组元素处理与多阶段流程控制

/**
 * 返回一个Promise，该Promise在指定延迟后解决。
 * @param {number} ms - 延迟的毫秒数。
 * @returns {Promise<void>}
 */
function delay(ms) {
  return new Promise(resolve => setTimeout(resolve, ms));
}

/**
 * 异步遍历数组，并在每次处理元素后引入延迟。
 * @param {Array<any>} arr - 要遍历的数组。
 * @param {Function} callback - 对每个元素执行的回调函数。
 * @param {number} elementDelayMs - 每个元素处理后的延迟毫秒数。
 * @returns {Promise<void>}
 */
async function processArrayWithDelay(arr, callback, elementDelayMs) {
  for (const item of arr) {
    callback(item); // 执行对当前元素的操作
    await delay(elementDelayMs); // 等待指定时间
  }
}

let currentArray = [1, 2, 3, 4, 5, 6, 7, 8, 9, 10];

/**
 * 第一阶段：打印数组中的所有数字，每个数字之间有1秒延迟。
 * @returns {Promise<void>}
 */
async function firstProcess() {
  console.log('--- 开始第一阶段：打印所有数字 ---');
  await processArrayWithDelay(currentArray, item => console.log(item), 1000);
  console.log('--- 第一阶段完成 ---');
}

/**
 * 第二阶段：从数组中移除奇数。这是一个同步操作，但作为整体阶段的一部分。
 * @returns {void}
 */
function secondProcess() {
  console.log('--- 开始第二阶段：移除奇数 ---');
  currentArray = currentArray.filter(num => num % 2 === 0);
  console.log('--- 第二阶段完成 ---');
}

/**
 * 第三阶段：打印剩余的偶数，每个数字之间有1秒延迟。
 * @returns {Promise<void>}
 */
async function thirdProcess() {
  console.log('--- 开始第三阶段：打印剩余偶数 ---');
  await processArrayWithDelay(currentArray, item => console.log(item), 1000);
  console.log('--- 第三阶段完成 ---');
}

/**
 * 编排整个多阶段任务流程。
 */
async function orchestrateProcesses() {
  // 执行第一阶段
  await firstProcess();
  // 等待2秒后进入下一阶段
  await delay(2000);

  // 执行第二阶段
  // 注意：secondProcess本身是同步的，但我们仍然需要等待其完成，
  // 并且在其后插入2秒的阶段间延迟。
  secondProcess();
  // 等待2秒后进入下一阶段
  await delay(2000);

  // 执行第三阶段
  await thirdProcess();
  console.log('--- 所有阶段执行完毕 ---');
}

// 启动整个流程
orchestrateProcesses();

/**
 * 返回一个Promise，该Promise在指定延迟后解决。
 * @param {number} ms - 延迟的毫秒数。
 * @returns {Promise<void>}
 */
function delay(ms) {
  return new Promise(resolve => setTimeout(resolve, ms));
}

/**
 * 异步遍历数组，并在每次处理元素后引入延迟。
 * @param {Array<any>} arr - 要遍历的数组。
 * @param {Function} callback - 对每个元素执行的回调函数。
 * @param {number} elementDelayMs - 每个元素处理后的延迟毫秒数。
 * @returns {Promise<void>}
 */
async function processArrayWithDelay(arr, callback, elementDelayMs) {
  for (const item of arr) {
    callback(item);
    await delay(elementDelayMs);
  }
}

let currentArray = [1, 2, 3, 4, 5, 6, 7, 8, 9, 10];

/**
 * 第一阶段：打印数组中的所有数字，每个数字之间有1秒延迟。
 * @returns {Promise<void>}
 */
async function firstProcess() {
  console.log('\n--- 开始第一阶段：打印所有数字 ---');
  await processArrayWithDelay(currentArray, item => console.log(item), 1000);
  console.log('--- 第一阶段完成 ---');
}

/**
 * 第二阶段：从数组中移除奇数。
 * @returns {void}
 */
function secondProcess() {
  console.log('\n--- 开始第二阶段：移除奇数 ---');
  const originalLength = currentArray.length;
  currentArray = currentArray.filter(num => num % 2 === 0);
  console.log(`已从数组中移除 ${originalLength - currentArray.length} 个奇数。`);
  console.log('当前数组:', currentArray);
  console.log('--- 第二阶段完成 ---');
}

/**
 * 第三阶段：打印剩余的偶数，每个数字之间有1秒延迟。
 * @returns {Promise<void>}
 */
async function thirdProcess() {
  console.log('\n--- 开始第三阶段：打印剩余偶数 ---');
  await processArrayWithDelay(currentArray, item => console.log(item), 1000);
  console.log('--- 第三阶段完成 ---');
}

/**
 * 编排整个多阶段任务流程。
 */
async function orchestrateProcesses() {
  try {
    // 执行第一阶段：打印所有数字
    await firstProcess();
    // 阶段间延迟：2秒
    await delay(2000);

    // 执行第二阶段：移除奇数
    secondProcess(); // 注意：此函数是同步的
    // 阶段间延迟：2秒
    await delay(2000);

    // 执行第三阶段：打印剩余偶数
    await thirdProcess();

    console.log('\n--- 所有阶段执行完毕 ---');
  } catch (error) {
    console.error('任务执行过程中发生错误:', error);
  }
}

// 启动整个流程
orchestrateProcesses();