Ожидание множества задач в цикле

Question

Мне нужно вызвать веб-службу несколько раз, потому что она имеет предел 100 объектов, возвращаемых за вызов, и я хочу сделать это параллельно.

Я делаю задачу для каждого вызова веб-службы, и я останавливаюсь, когда задача возвращает меньше предела элементов, а это значит, что больше нет предметов для получения.

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 
    }