のSystem.InvalidOperationException：コレクションが

Question

キューを列挙しながら、私は次の例外を取得しています修正されました：

のSystem.InvalidOperationException： コレクションが変更されました。列挙 操作はここ

を実行しないかもしれないコードの抜粋です：

1: private bool extractWriteActions(out List<WriteChannel> channelWrites) 
2: { 
3:  channelWrites = new List<WriteChannel>(); 
4:  foreach (TpotAction action in tpotActionQueue) 
5:  { 
6:   if (action is WriteChannel) 
7:   { 
8:    channelWrites.Add((WriteChannel)action); 
9:    lock(tpotActionQueue) 
10:    { 
11:     action.Status = RecordStatus.Batched; 
12:    } 
13:   } 
14:  } 
15:  return (channelWrites.Count > 0); 
16: } 

私は問題を理解すると思う - action.Status = RecordStatus.Batchedでハッシュテーブルを変更すること、ねじアップ列挙子のMoveNextメソッドは（）。質問は、どのように私はその "パターン"を正しく実装するのですか？

Answer 1

コレクション内のアイテムの値を変更することはできます。取得したエラーは、アイテムが追加または削除されたことを意味します。つまり、コレクション自体が変更されたもので、コレクション内のアイテムではありません。これは、このコレクションにアイテムを追加または削除する別のスレッドが原因である可能性が最も高いです。

他のスレッドがアクセスしている間にコレクションを変更しないようにするには、メソッドの先頭にキューをロックする必要があります。または、このメソッドを呼び出す前にコレクションをロックすることもできます。

private bool extractWriteActions(out List<WriteChannel> channelWrites) 
    { 
     lock(tpotActionQueue) 
     { 
     channelWrites = new List<WriteChannel>(); 
     foreach (TpotAction action in tpotActionQueue) 
     { 
      if (action is WriteChannel) 
      { 
       channelWrites.Add((WriteChannel)action); 

        action.Status = RecordStatus.Batched; 

      } 
     } 
     } 
     return (channelWrites.Count > 0); 
    } 

Answer 2

私はあなたがする必要があるすべてはforeachの使用を中止し、代わりに、ループの

for(int i = 0; i < tpotActionQueue.Length; i++) 
{ 
    TpotAction action = tpotActionQueue[i]; 

    if (action is WriteChannel) 
    { 
     channelWrites.Add((WriteChannel)action); 
     lock(tpotActionQueue) 
     { 
      action.Status = RecordStatus.Batched; 
     } 
    } 
} 

よろしく、マイクにそれを切り替えることだと思います。

Answer 3

私はあなたがそれを反復している間にtpotActionQueueを変更する他のスレッドを持っている必要があると思います。 forループの中でキューをロックするだけなので、これは可能です。

Answer 4

は私がコレクションから項目を削除しようとしたコレクションにforeachループを使用しているとき、私は同様の例外を持っていたと思います（またはそれは、私が覚えていないことのリストをされている場合があります）。私はforループを使って周りを回った。おそらく、次のようなものを試してください：

for (int i=0; i<tpotActionQueue.Count(); i++) 
{ 
    TpotAction action = tpotActionQueue.Dequeue(); 
    if (action is WriteChannel) 
    { 
     channelWrites.Add((WriteChannel)action); 
     lock(tpotActionQueue) 
     { 
      action.Status = RecordStatus.Batched; 
     } 
    } 
} 

Answer 5

あなたはtpotActionQueueの定義を持っていないが、それは普通のList<TpotAction>だ場合、その行はあなたの問題ではありません。コレクションを変更するのは、メンバーを追加または削除することです。含まれているオブジェクトのプロパティを設定するのではありません。

あなたはlock(tpotActionQueue)とスレッドセーフのタグを持っていますので、列挙中にtpotActionQueueからアイテムを追加または削除する別のスレッドがあります。おそらくそれらのアクセスを同期させる必要があります。

Answer 6

LINQyの良さはどうですか？

private bool extractWriteActions(out List<WriteChannel> channelWrites) 
{ 

    channelWrites= tpotActionQueue.Where<WriteChannel>(x => x is WriteChannel).ToList() 

    foreach(WriteChannel channel in channelWrites) { 
     channel.Status = RecordStatus.Batched; 
    } 

    return (channelWrites.Count > 0); 
}