等待循環中的多個任務

Question

我需要多次調用Web服務，因爲它有每次調用返回的100個對象的限制，並且我想要並行執行此操作。

我正在爲每個Web服務調用做一個任務，並且當任務返回小於項目限制時停止，這意味着沒有更多項目要獲取。

public static async Task<List<Space>> GetSpacesByTypeParallel(SpaceType type, string ticket, int degreeOfParallelism) 
{ 
    int offset = 0; 
    int batchSize = degreeOfParallelism * RETURN_LIMIT; 
    List<Space> spaces = new List<Space>(); 
    Task<List<Space>>[] tasks = new Task<List<Space>>[degreeOfParallelism]; 
    bool shouldContinue = true; 
    while(shouldContinue) 
    { 
     for(int i = 0; i < degreeOfParallelism; i++) 
     { 
      tasks[i] = Task.Run<List<Space>>(() => GetSpacesAtOffset(offset + (i * RETURN_LIMIT), RETURN_LIMIT, ticket, null, type.ToString())); //GetSpacesAtOffset is a synchronous method 
     } 

     List<Space>[] result = await Task.WhenAll(tasks); 

     foreach(List<Space> item in result) 
     { 
      spaces.AddRange(item); 
      if(item.Count < RETURN_LIMIT) 
      { 
       shouldContinue = false; 
      } 
     } 

     offset += batchSize; 
    } 
    return spaces; 
} 

我出於測試目的同步運行以下命令：

var spaces = Space.GetSpacesByType(SpaceType.Type1, ticket).Result; 

然而，這總是返回一個空列表，但如果我使用調試器逐句通過它做它應該。

我在做什麼錯？

Answer 1

我相信這是由閉包變量造成的。嘗試將其更改爲

for(int i = 0; i < degreeOfParallelism; i++) 
    { 
     var n = i; 
     tasks[i] = Task.Run<List<Space>>(() => GetSpacesAtOffset(offset + (n * RETURN_LIMIT), RETURN_LIMIT, ticket, null, type.ToString())); //GetSpacesAtOffset is a synchronous method 
    }