并行动态提取请求

Question

我想知道如何并行执行动态提取请求，我一直在尝试这样做12个小时，但我无法弄清楚，我在Google和Stackoverflow上到处都看，我真的很累。

      for (const fileindex of filelist) {
        let dcmFilename = `slice_${fileindex}.dcm`
        slices.push( {index:fileindex, filename:dcmFilename} )
          fd.append(dcmFilename, files[fileindex], dcmFilename);
        fd.append('slices', JSON.stringify(slices));
        loopcount += 1
        if (filecount == 24 || loopcount == filelist.length){
          
      if (cursorPos !== false) {
        let scaleFactor = Tegaki.scaleFactor;
        cursorPos.x = parseInt(cursorPos.x / scaleFactor);
        cursorPos.y = parseInt(cursorPos.y / scaleFactor);
        fd.append('x', cursorPos.x);
        fd.append('y', cursorPos.y)
      }

      // Get layer id from index
      if (index !== -1) {
        type = this.layerTypes[index]['id']
      }
      // switch mode from heuristic to pytorch vertebrae for vertebral bone
      if (type === 'vertebral-bone' ){
        mode='PyTorch-Vertebrae'
      }

      // Post to endpoint
      let domain = window.location.origin.replace(':8080', ':5000')
      let list = await fetch(`${domain}/segment?mode=${mode}&type=${type}`,  {    method: 'POST', body: fd   })
      let result = await list.json()
      // do something with result
      // finish then continue the loop and create new body and send a new request
     // clear formdata and continue loop
     fd =  new FormData()
}

我有以下我发送的提取请求，在每个请求生成主体的地方，它永远不会是相同的身体，身体会通过功能动态生成。有没有办法一次发送所有请求，然后等待他们返回响应，然后继续我的其余代码？

Answer 1

您可以在其中使用等待等待等待，而不是，您可以使用filelist.map（）与async 回调。

由于.map（）只是盲目地迭代数组而无需等待任何返回的承诺，因此它将从所有async回调.map（map .map（map）中返回一系列承诺）调用。这些承诺最初将无法实现，所有fetch（）操作将同时“飞行”。然后，您可以使用等待Promise.All（...）在返回的承诺阵列上都知道它们何时完成：

await Promise.all(filelist.map(async fileindex => {
    let dcmFilename = `slice_${fileindex}.dcm`
    slices.push({ index: fileindex, filename: dcmFilename })
    fd.append(dcmFilename, files[fileindex], dcmFilename);
    fd.append('slices', JSON.stringify(slices));
    loopcount += 1
    if (filecount == 24 || loopcount == filelist.length) {

        if (cursorPos !== false) {
            let scaleFactor = Tegaki.scaleFactor;
            cursorPos.x = parseInt(cursorPos.x / scaleFactor);
            cursorPos.y = parseInt(cursorPos.y / scaleFactor);
            fd.append('x', cursorPos.x);
            fd.append('y', cursorPos.y)
        }

        // Get layer id from index
        if (index !== -1) {
            type = this.layerTypes[index]['id']
        }
        // switch mode from heuristic to pytorch vertebrae for vertebral bone
        if (type === 'vertebral-bone') {
            mode = 'PyTorch-Vertebrae'
        }

        // Post to endpoint
        let domain = window.location.origin.replace(':8080', ':5000')

        let list = await fetch(`${domain}/segment?mode=${mode}&type=${type}`, { method: 'POST', body: fd })
        let result = await list.json()
        // do something with result
        // finish then continue the loop and create new body and send a new request
    }
}));

注释＃1：，因为您现在正在运行多次获取操作并行，任何对其结果处理的代码都不得共享变量。您在此代码中有几个变量，这些变量未显示其声明。这些声明可能应该在此循环内部使用LET或const，因此循环的每个迭代都有一个新变量，除非变量为明确应该在迭代中积累。此循环中的可疑变量没有可能受并行操作影响的本地声明是filecount，loopcount，cursorpos，index index代码>，<代码>模式 fd和type。您不会在此处显示整个执行上下文，因此我们看不到足够的内容来对其进行完整的建议。

注释＃2：包含此的代码if（fileCount == 24 || loopcount == filelist.length）看来它可能容易出现问题。如果您在完成所有迭代时要运行一些代码，那么在promise.all（）之后运行该代码比尝试检测何时完成您的上一次迭代会更好。请记住，您的迭代不一定会立即进行，因为您正在并行运行它们。他们将按顺序启动，但不一定按顺序完成。