反復処理中にListItemをリストに追加する方法（C＃）

Question

私はBackgroundWorkerを使っていつもIEnumerator<T> listを処理する小さなアプリケーションを持っています。

コードは基本的にこのような：

while(true){ 
    foreach(T item in list){ 
     // Process each item and send process 
     // Add an object in child List (List<T1> item.Result) 
    } 
    Thread.Sleep(500); 
} 

今、私はIEnumeratorを直接追加しますこれ、ボタンやテキストボックスを持っています。

問題は、ボタンを追加した後、バックグラウンド作業者は現在処理中のアイテムを処理し続けますが、そのアイテムを終了した後は停止するということです。それは続かない。

項目を背景に影響を与えずにリストに安全に追加するにはどうすればよいですか？バックグラウンドワーカーの横にもアイテムにオブジェクトを追加します。このための解決策は何でしょうか？

はおそらくsimultaniouslyコードの両方の場所から共有「リスト」変数にアクセスしないようにする「ロック」キーワードを使用する必要が

Answer 1

元のリストのコピーではなく、リスト自体の上にバックグラウンドワーカー反復を持っています。

while (true) 
{ 
     foreach (T item in new List<T>(list)) 
     { 
      .... 
     } 
     Thread.Sleep(500); 
} 

あなたはそれの上に列挙しながら、コレクションを変更しようとすると、列挙子は例外をスローします。 docsから：コレクションが変更されない のままとして

列挙子は限り有効です。追加、 要素の変更または削除などのコレクションに変更が加えられた場合、列挙子は無効になり、 が無効になり、次のMoveNextまたはResetの呼び出しによって InvalidOperationExceptionがスローされます。コレクションが MoveNextとCurrentの間で変更された場合、列挙子が既に無効化されていても、Currentはそれが設定されている要素 を返します。

Answer 2

ありがとうございます。

http://msdn.microsoft.com/en-us/library/c5kehkcz(v=vs.71).aspx

Answer 3

まず、マルチスレッドプログラミングの基本を学ぶ必要があります。

がこの沿って何かを試してみてください：

// shared queue 
ConcurrentQueue<T> queue = new ConcurrentQueue<T>(); 
// shared wait handle 
AutoResetEvent autoEvent = new AutoResetEvent(); 

それはあなたが現在の要素のインデックスを気にせずにそれから要素を追加したり削除することができますので、キューは、ここにリストよりも優れている - あなただけのEnqueue()アイテムもう片方にはDequeue()があります。 System.Collections.Concurrent名前空間のクラスを使用すると、スレッドセーフなアクセスが自動的に処理されます（また、複雑な理由により、後で読みたい場合があるため、単純なlock()よりも高速です）。

は今、フォアグラウンドスレッド：

// schedule the work 
queue.Enqueue(itemOfWork); 
// and wake up our worker 
autoEvent.Set(); 

ここsprinkly-魔法の一部は（はい、AutoResetEventはWaitHandleの実装です）私たちのWaitHandleで呼び出さSet()です。Thread.Sleep()のような醜い構文を使わずに、同期イベントが発生するのを待っていた1つのスレッドを起動します。 Sleep()への呼び出しは、ほとんどの場合、マルチスレッドコードの間違いの兆候です。

最後の部分は、ワーカースレッドです。ここにあまり変更がありません：

while(true) 
{ 
    // wait for the signal 
    autoEvent.WaitOne(); 
    T item; 
    // grab the work item 
    queue.TryDequeue(out item); 

    // handle the item here; 
}