Come aggiungere una raccolta IEumerable a una coda ed elaborare ogni elemento in modo asincrono in .NET?

Question

Ho creato un metodo per leggere nuovi messaggi nella posta in arrivo utilizzando il server di scambio come di seguito. Come aggiungere questa raccolta IEnumerable a una coda ed elaborare ogni elenco di elementi all'interno della coda in modo asincrono?

private static IEnumerable<ExchangeEmailInformation> GetInboxItems(ExchangeService service) 
{ 
    var emailInformations = new List<ExchangeEmailInformation>(); 
    try 
    {  
     SearchFilter searchFilter = new SearchFilter.SearchFilterCollection(LogicalOperator.And, new SearchFilter.IsEqualTo(EmailMessageSchema.IsRead, false)); 
     var itemview = new ItemView(int.MaxValue); 
     FindItemsResults<Item> findResults = service.FindItems(WellKnownFolderName.Inbox, searchFilter, itemview); 
     Console.WriteLine("\n-------------Result found:-------------"); 
     service.LoadPropertiesForItems(findResults, PropertySet.FirstClassProperties); 

     foreach (var item in findResults) 
     { 
      emailInformations.Add(new ExchangeEmailInformation 
      { 
       Attachment = item.Attachments ?? null, 
       Body = item.Body.BodyType == BodyType.HTML ? ConvertHtml.ToText(item.Body.Text) : item.Body.Text, 
       Subject = item.Subject, 
       RecievedDate = item.DateTimeReceived 
      }); 
     } 
    } 
    catch (Exception ee) 
    { 
     Console.WriteLine("\n-------------Error occured:-------------"); 
     Console.WriteLine(ee.Message.ToString()); 
     Console.WriteLine(ee.InnerException.ToString()); 
     Console.ReadKey(); 
    } 
    return emailInformations; 
} 

Il sotto sono il processo ho bisogno di chiamare in modo asincrono utilizzando ogni articoli in coda

static void AddAttachment(string subject ,string docId, string user, string fileName) 
{ 
    var url = new StringBuilder(); 
    url.Append(string.Format("https://webdemo-t.test.com:8443/Services/Service/MyService.svc/AddAttachment?User={0}&Engagement={1}&FileName={2}&DocumentTrasferID={3}", user, subject, fileName, docId)); 

    Console.WriteLine(url.ToString()); 
    WebRequest request = WebRequest.Create(url.ToString()); 
    var credential = new NetworkCredential("user", "xxxx", "xxxx"); 
    request.Credentials = credential; 
    WebResponse ws = request.GetResponse(); 
    Encoding enc = System.Text.Encoding.GetEncoding(1252); 
    var responseStream = new StreamReader(ws.GetResponseStream()); 
    string response = responseStream.ReadToEnd(); 
    responseStream.Close(); 
    Console.WriteLine(response); 
} 

Answer 1

Si può iniziare nuovo compito per ogni allegato. Non è necessario pensare al numero di attività che si generano. Le attività non sono associate a Thread 1 di 1.

foreach (var item in findResults) 
{ 
    emailInformations.Add(new ExchangeEmailInformation ...); 

    // start new task 
    Task.Factory.Start(() => { 
     AddAttachment(item.Subject, item.docId, item.User ...); 
    }) 
} 

Questo metodo non richiede l'utilizzo di API asincrone.

Un altro modo è utilizzare l'API asincrona delle classi WebRequest/WebResponse.

Answer 2

Se .NET è 4.0 o smth, hai provato il metodo di estensione AsParallel?