在可能的情況下處理異常，同時獲取數據

Question

下面是我用來從多個url檢索數據的代碼。對於幾個網址，我會得到例外，但對於其他所有其他網站我都會收到有效的數據。問題是，在下面的應用程序中，我無法收集能夠在沒有任何問題的情況下檢索數據的線程的數據。無論如何收集儘可能多的網址迴應，同時也知道哪些網址引發異常？

static void Main(string[] args) 
{ 
    var URLsToProcess = new List<string> 
      { 
       "http://www.microsoft.com", 
       "http://www.stackoverflow.com", 
       "http://www.google.com", 
       "http://www.apple.com", 
       "http://www.ebay.com", 
       "http://www.oracle.com", 
       "http://www.gmail.com", 
       "http://www.amazon.com", 
       "http://www.outlook.com", 
       "http://www.yahoo.com", 
       "http://www.amazon124.com", 
       "http://www.msn.com" 
       }; 

    string[] tURLs = null; 
    try 
    { 
     tURLs = URLsToProcess 
      .AsParallel() 
      .WithDegreeOfParallelism(3) 
      .Select(uri => DownloadStringAsTask(new Uri(uri)).Result) 
      .ToArray(); 
    } 
    catch (AggregateException ex) 
    { 
     AggregateException exf = ex.Flatten(); 

    } 
    Console.WriteLine("download all done"); 
    if (tURLs != null) 
    { 
     foreach (string t in tURLs) 
     { 
      Console.WriteLine(t); 
     } 
    } 
} 

static Task<string> DownloadStringAsTask(Uri address) 
{ 
    TaskCompletionSource<string> tcs = 
     new TaskCompletionSource<string>(); 
    WebClient client = new WebClient(); 
    client.DownloadStringCompleted += (sender, args) => 
    { 
     if (args.Error != null) 
      tcs.SetException(args.Error); 
     else if (args.Cancelled) 
      tcs.SetCanceled(); 
     else 
      tcs.SetResult(args.Result); 
    }; 
    client.DownloadStringAsync(address); 
    return tcs.Task; 
} 

Answer 1

是的，有：

var tasks = URLsToProcess.Select(uri => DownloadStringAsTask(new Uri(uri))).ToArray(); 

while (tasks.Any()) 
{ 
    try 
    { 
     Task.WaitAll(tasks); 
     break; 
    } 
    catch (Exception e) 
    { 
     // handle exception/report progress... 
     tasks = tasks.Where(t => t.Status != TaskStatus.Faulted).ToArray(); 
    } 
} 

var results = tasks.Select(t => t.Result); 

使用Task.WaitAll等待（同步，因爲async-await不可用）的同時所有的任務來完成。如果Task.WaitAll成功完成，跳出while循環並使用Task.Result提取結果。如果發生異常，請移除故障任務並再次等待其他任務等等。