Создать тему, которая запускает несколько других потоков

Question

Я ищу запрос данных с разных конечных точек, внутри метода контроллера. Я только хочу вернуть View(), когда все эти запросы будут выполнены. Можно ли это сделать, и как это можно сделать?

Прямо сейчас я делаю что-то близкое к этому

class GetDemData 
{ 
    int count = 0; 
    int requestsCompleted = 0; 

    List<string> addresses = new List<string>(); 

    public void AddDataToBeCollected(string address) 
    { 
     adresses.Add(address); 
    } 

    public void CollectData() 
    { 
     foreach (string address in addresses) 
     { 
      HttpClient client = new HttpClient(); 
      client.BaseAddress = new Uri("http://localhost:1337/"); 
      client.GetAsync(address).ContinueWith(
       getTask => 
        { 
         if (getTask.IsCanceled) 
         { 
          error(); 
         } 
         else if(getTask.IsFaulted) 
         { 
          error(); 
         } 
         else 
         { 
          requestsCompleted++; 
          checkFinished(); 
         } 
        } 
      ); 
     } 
    } 

    public void checkFinished() 
    { 
     if (count == requestsCompleted) 
     { 
      // All data collected 
     } 
    } 

    public void error() 
    { 
     // yes error 
    } 
} 

И это мой контроллер

public ActionResult GetData() 
{ 
    var data = new GetDemData(); 
    // fill data with addresses 
    data.CollectData(); 

    return View(); 
} 

Проблема заключается в том, так как все делается асинхронной, вид сразу вернулся. Как я могу убедиться, что представление возвращается только после сбора всех данных?

Answer 1

public class GetDemData 
{ 

    List<string> addresses = new List<string>(); 

    public void AddDataToBeCollected(string address) 
    { 
     adresses.Add(address); 
    } 

    public Task CollectData() 
    { 
       var webclient = new WebClient(); 
       var tasks = from address in addresses 
          select webclient.DownloadStringTaskAsync(address); 

       return Task.WhenAll(tasks.Select(
          async (downloadTask) => 
          { 
           var result = await downloadTask; 
           //Do somthing with result 
          })); 
    } 

} 


public async Task<ActionResult> GetData() 
{ 
    var data = new GetDemData(); 
    // fill data with addresses 
    await data.CollectData(); 

    return View(); 
} 

Answer 2

Вам необходимо сохранить ссылку на экземпляры Task, а затем вызвать .Wait() в этой задаче, чтобы принудительно заблокировать поток до тех пор, пока эти запросы не будут выполнены. Например:

Answer 3

Вы не можете использовать простой асинхронный/ожидающий, если хотите сразу запустить все запросы. например, если вы использовали await внутри своей петли, он по-прежнему запускал бы один запрос за раз, дождитесь его завершения, затем запустит следующий запрос. Вместо этого вам нужно запустить все запросы, собрать полученные объекты Task и дождаться завершения их всех.

public Task CollectData() 
{ 
    var tasks = new List<Task>(); 
    foreach (string address in addresses) 
    { 
     HttpClient client = new HttpClient(); 
     client.BaseAddress = new Uri("http://example.com:1337/"); 

     //Note we're collecting the resulting Task objects here 
     //We're actually getting the task from the continuation, which is a little bit weird 
     //Alternatively, you could break this into another method that uses await internally 
     var task = client.GetAsync(address).ContinueWith(
      getTask => 
       { 
        if (getTask.IsCanceled) 
        { 
         error(); 
        } 
        else if(getTask.IsFaulted) 
        { 
         error(); 
        } 
        else 
        { 
         requestsCompleted++; 
         checkFinished(); 
        } 
       } 
     ); 
     tasks.Add(task); 
    } 

    //Return a single task that completes when all the subtasks are done 
    return Task.WhenAll(tasks.ToArray()); 
} 

контроллер ...

public async Task<ActionResult> GetData() 
{ 
    var data = new GetDemData(); 
    // fill data with addresses 
    var task = data.CollectData(); 
    await task; 
    return View(); 
} 

Update, несколько чище способ сделать это, используя отдельный метод, который стреляет только один запрос. Кроме того, я просто заметил, что вы не используете HttpClient правильно - это IDisposable, а также содержит внутренний пул запросов, поэтому его следует использовать повторно, а не создавать и уничтожать по запросу.

public async Task CollectData() 
{ 
    var tasks = new List<Task>(); 
    using (var client = new HttpClient()) 
    { 
     foreach (string address in addresses) 
     { 
      tasks.Add(ExecuteSingleRequest(client, address)); 
     } 

     await Task.WhenAll(tasks.ToArray()); 
    } 
} 

private async Task ExecuteSingleRequest(HttpClient client, Uri uri) 
{ 
    try 
    { 
     var response = await client.GetAsync(uri); 
    } 
    catch (Exception ex) 
    { 
     //This is lazy example code, do real error handling here and don't catch Exception 
    } 
}