如何控制async函数的执行流程？实现按序执行、失败超时可重试的优雅方案

核心思路 #

把重试、超时逻辑和业务函数解耦，封装为通用高阶工具函数，再配合async/await替代嵌套then链，既保证逻辑清晰，又能灵活配置每个步骤的重试规则。

具体实现 #

1. 基础工具函数封装 #

// 超时包装：指定时间内函数未返回则抛出超时错误
function withTimeout(fn, timeoutMs) {
  return async (...args) => {
    return Promise.race([
      fn(...args),
      new Promise((_, reject) => {
        setTimeout(() => reject(new Error(`执行超时，阈值${timeoutMs}ms`)), timeoutMs)
      })
    ])
  }
}

// 重试+超时组合包装
function withRetry(fn, maxRetry, timeoutMs) {
  const fnWithTimeout = withTimeout(fn, timeoutMs)
  return async (...args) => {
    let attemptCount = 0
    while (attemptCount < maxRetry) {
      try {
        return await fnWithTimeout(...args)
      } catch (err) {
        attemptCount++
        // 达到最大重试次数后抛出最终错误
        if (attemptCount >= maxRetry) {
          throw new Error(`累计重试${maxRetry}次全部失败，最后错误：${err.message}`)
        }
        // 可选：加指数退避延迟，避免短时间频繁重试压垮接口
        await new Promise(resolve => setTimeout(resolve, 100 * Math.pow(2, attemptCount)))
      }
    }
  }
}

2. 调用链实现（推荐async/await写法） #

完全替代嵌套then结构，逻辑线性展开，可读性更高，每个步骤可单独配置重试规则：

async function runAsyncChain() {
  try {
    // 每个步骤可自定义重试次数、超时时间
    const resultA = await withRetry(funcA, 3, 2000)() // 重试3次，单次超时2s
    const resultB = await withRetry(funcB, 2, 3000)(resultA) // 重试2次，单次超时3s
    const resultC = await withRetry(funcC, 4, 1000)(resultB) // 重试4次，单次超时1s
    // 后续业务逻辑
  } catch (finalErr) {
    // 整个调用链最终失败的兜底处理
    console.error('调用链执行失败：', finalErr)
  }
}

runAsyncChain()

3. 兼容Promise.then链式写法 #

如果需要保留原有then链的写法，也可以直接把包装后的函数传入then：

withRetry(funcA, 3, 2000)()
  .then(resultA => withRetry(funcB, 2, 3000)(resultA))
  .then(resultB => withRetry(funcC, 4, 1000)(resultB))
  .then(/* 后续业务逻辑 */)
  .catch(finalErr => console.error('调用链执行失败：', finalErr))

方案优势 #

• 逻辑解耦：重试、超时逻辑和业务代码完全分离，修改规则不需要调整业务函数
• 灵活度高：每个步骤可单独配置重试次数、超时时间，也可选择是否开启重试
• 易维护扩展：新增调用步骤直接加在async函数里即可，不会出现then嵌套地狱
• 易调试：可在重试逻辑里统一加日志埋点，输出每次重试的错误原因

内容的提问来源于stack exchange，提问作者modular-monolith