HarmonyOS 鸿蒙Next关于TaskGroup的执行异常

HarmonyOS 鸿蒙Next关于TaskGroup的执行异常 需求背景：批量下载zip的需求

1：下载前先判读本地是否有zip资源包。解压缩成功则完成当前任务，如果不存在或解压缩失败，则进行第二步下载文件。

2：下载文件

3：解压缩下载后的zip文件

报错如下：

代码如下：

public parse(urls: Set<Resource>) {
  const resources = new Array<ResourceInfo>()
  urls.forEach((res) => {
    const fileInfo = this.parseUrl(res)
    if (fileInfo == undefined) return
    resources.push(fileInfo)
  })
  const needDownloadResources = new Array<ResourceInfo>()
  this.executeUnzipTask(resources).then((results) => {
    // 找出来需要下载的文件
    results.forEach((val) => {
      if (val.needDownload) {
        needDownloadResources.push(val.resource)
      }
    })
    if(needDownloadResources.length == 0) {
      console.info(`[cocos]资源解析完成`)
      return
    }
    // 执行下载任务
    this.executeDownloadTask(needDownloadResources).then((results) => {
      console.info(`[cocos]下载完成，开始解压`)
      this.executeUnzipTask(results).then((results) => {
        console.info(`[cocos]解压缩完成`)
        results.forEach((val) => {
          if (val.needDownload) {
            // 如果此处还有需要下载的文件，则忽略下载，打印错误信息
            console.error(`[cocos]已经下载过一次，忽略下载: ${val.resource.url}`)
          }
        })
      }).catch((error: Error) => {
        console.info(`[cocos]解压缩失败: ${error}`)
      })
    })
  }).catch((error: Error) => {
    console.info(`[cocos]解压缩失败: ${error}`)
  })
}

/*
 * 批量解压缩
 * */
private executeUnzipTask(resources: Array<ResourceInfo>): Promise<UnzipResponse>[] {
  console.info(`[cocos]开始解压缩${resources.length}个资源`)
  const unzipTaskGroup = new taskpool.TaskGroup()
  resources.forEach((val) => {
    unzipTaskGroup.addTask(unzipTask, val)
  })
  return taskpool.execute(unzipTaskGroup) as Promise<UnzipResponse>[]
}

/*
 * 批量下载文件
 * */
private async executeDownloadTask(resources: Array<ResourceInfo>): Promise<Array<ResourceInfo>> {
  const promises = new Array<Promise<ResourceInfo>>()
  resources.forEach(async (resource) => {
    const downloadPromise = new Promise<ResourceInfo>(async (resolve, reject) => {
      const config: request.agent.Config = {
        action: request.agent.Action.DOWNLOAD,
        url: resource.url,
        overwrite: true,
        saveas: resource.zipPath
      }
      const task = await request.agent.create(getContext(), config)
      task.on('progress', (progress) => {
        console.info(`[cocos]${resource.id} 下载进度: ${progress.processed}`)
      })
      task.on('completed', async (progress) => {
        // 执行解压缩
        resolve(resource)
      })
      task.on('failed', (progress) => {
        reject(new Error(`download failed: ${resource.url}`))
      })
      task.start()
    })
    promises.push(downloadPromise)
  })
  return Promise.all(promises).catch((error: Error) => {
    console.error(`[cocos] 下载任务失败: ${error.message}`);
    throw error;
  })
}

private parseUrl(res: Resource): ResourceInfo|undefined {
  const url = res.url
  const url_splits = url.split('/')
  if (url_splits.length == 0) return undefined
  const fileName = url_splits.pop()
  const fileNameInfoArray = fileName?.split('_md5_') ??
  if(fileNameInfoArray.length != 2) return undefined
  const md5 = fileNameInfoArray[1].replace('.zip', '')
  let unzipPath = this.unzipDir + `/${fileName?.replace('.zip', '')}`
  if (res.isPublicRes) {
    unzipPath = this.unzipDir + '/public'
  }
  const zipPath = this.zipDir + `/${fileName}`
  return {
    "url": url,
    "fileName": fileName,
    "md5": md5.toUpperCase(),
    "zipPath": zipPath,
    "unzipPath": unzipPath,
    "id": res.id
  } as ResourceInfo
}

以下是异步解压缩代码
/*
 * 对一个资源进行zip解压缩
 * 返回值：true需要下载资源，false不需要下载资源
 * */
@Concurrent
export async function unzipTask(resource: ResourceInfo): Promise<UnzipResponse> {
  const zipFileExit = await fs.access(resource.zipPath)
  if (!zipFileExit) return { resource: resource, needDownload: true }
  // zip文件存在
  const unzipFileExit = await fs.access(resource.unzipPath)
  if (!unzipFileExit) {
    await fs.mkdir(resource.unzipPath)
  }
  try {
    await zlib.decompressFile(resource.zipPath, resource.unzipPath)
    return { resource: resource, needDownload: false }
  } catch (err) {
    console.error(`解压缩失败: ${err}`)
    return { resource: resource, needDownload: true }
  }
}