ループ内で複数のスレッドを実行する方法

Question

私は現在、多くの時間がかかるタスクを実装しています。 基本的に、私がしたいのは、foreachループ内で複数のタスクを実行することです。 Parallel.ForEachを使用して私のUIをフリーズしようとしました。私は一度に10のuidのように呼びたいと思う。ここで

foreach (var uid in listBox2.Items) 
       { 
        if (StopEmail) break; 
        Application.DoEvents(); 
        string jsonstring = GetEmails(uid.ToString(), token); 
        if (jsonstring != null) 
        { 
         label6.Text = " Current UID: " + listBox2.Items.IndexOf(uid); 
         dynamic jsonResponse = JsonConvert.DeserializeObject(jsonstring); 
         string idstt = jsonResponse["email"]; 
         if (idstt != null) 
         { 
          listBox3.Items.Add(idstt); 
          label4.Text = "Total Emails: " + listBox3.Items.Count.ToString(); 

         } 
        } 
       } 

は私Parallel.ForEachコード：

var files = listBox2.Items.Cast<String>().ToList(); 
Parallel.ForEach(files, uid => 
{ 
    Application.DoEvents(); 
    string jsonstring = GetEmails(uid.ToString(), token); 
    if (jsonstring != null) 
    { 
     this.Invoke(new MethodInvoker(delegate() 
     { 
      label6.Text = " Current UID: " + listBox2.Items.IndexOf(uid); 
     })); 

     dynamic jsonResponse = JsonConvert.DeserializeObject(jsonstring); 
     string idstt = jsonResponse["email"]; 
     if (idstt != null) 
     { 
      this.Invoke(new MethodInvoker(delegate() 
      { 
       listBox3.Items.Add(idstt); 
       label4.Text = "Total Emails: " + listBox3.Items.Count.ToString(); 
      })); 
     } 
    } 
}); 

Answer 1

ここでは、Microsoftのリアクティブフレームワーク（NuGet "System.Reactive.Windows.Forms"）を使用します。すべてうまくqueryで扱われるように遅い部分がGetEmailsコールである

var uids = listBox2.Item.Cast<String>().ToArray(); 

var query = 
    from uid in uids.ToObservable() 
    from jsonstring in Observable.Start(() => GetEmails(uid, token)) 
    where jsonstring != null 
    select new { uid, jsonstring }; 

IDisposable subscription = 
    query 
     .ObserveOn(this) 
     .Subscribe(x => 
     { 
      label6.Text = " Current UID: " + listBox2.Items.IndexOf(x.uid); 
      dynamic jsonResponse = JsonConvert.DeserializeObject(x.jsonstring); 
      string idstt = jsonResponse["email"]; 
      if (idstt != null) 
      { 
       listBox3.Items.Add(idstt); 
       label4.Text = "Total Emails: " + listBox3.Items.Count.ToString(); 
      } 
     }); 

：

その後、あなたはこれを行うことができます。

.ObserveOn(this)コールはコードをUIスレッドに戻してマーシャリングしますので、乱雑ではありません.Invoke呼び出しが必要です。

最後に、計算を早く終了するには、subscription.Dispose()と呼んでください。

Answer 2

はTask.Runコールの内側にあなたのParallel.ForEachをラップ：

var files = listBox2.Items.Cast<String>().ToList(); 
Task task = Task.Run(() => { 

    Parallel.ForEach(files, uid => 
    { 
     // remove the `Application.DoEvents()` call, it is unnecessary 
     // ... 
    } 

}); 

を代わりにForEachからデータを返すために、より良いデザインかもしれメソッドを.Invokeと呼ぶのではなく、awaitを使用してUIを更新することもできますForEachが完成しましたが、これはループと目的のUXの性質によって異なります。