どのようにして.netでブロック列挙を終了できますか？

Question

BlockingCollectionと同様のforeachというセットを公開するライブラリを使用します。ここで、列挙子は次のアイテムが提供されるまで待機します。

foreach(var item in items) 
{ 
    ... 
} 

私の消費者は、次のアイテムが提供されるまでforeachを待つでしょう。準備が整うまでブロックに入りません。これは問題ありませんが、私が現在待っている場合でも、特定の条件下で列挙を意図的に停止したいと考えています。

ブロック内にbreakについて質問していません。私がブロックにいるときにループを終了するのは簡単です。列挙を別のスレッドから「取り消したい」。

Answer 1

これはかなりありませんが、BackgroundWorkerまたは他のスレッド技法の中でこれを囲むことができます。

私はあなたのBlockingCollectionがあるが、私はそれがBlockingItemコレクションで構成されていることを以下のコードのために前提となるかわかりません。

private bool _someExternalFlag; 

private void Test(BlockingCollection items) 
{ 
    _someExternalFlag = false; 
    using (var worker = new BackgroundWorker()) 
    { 
     worker.WorkerReportsProgress = true; 
     worker.WorkerSupportsCancellation = true; 
     worker.DoWork += delegate 
     { 
      var index = 0; 
      foreach (var item in items) 
      { 
       if (worker.CancellationPending) 
       { 
        break; 
       } 
       index++; 
       // ... process your item here or by passing it to the main thread 
       worker.ReportProgress(index, item); 
      } 
     }; 
     worker.ProgressChanged += delegate(object sender, ProgressChangedEventArgs e) 
     { 
      if (_someExternalFlag) 
      { 
       worker.CancelAsync(); 
      } 
      else 
      { 
       var item = e.UserState as BlockingItem; 
       // use item if you need it 
      } 
     }; 
     worker.RunWorkerAsync(); 
    } 
} 

はあなたのBackgroundWorkerのDoWorkメソッドは、解放される次のBlockingItemを待っている間に任意のCPUリソースを占有するつもりはありません。

変数Iが_someExternalFlagと定義されている場合は、ユーザーがキャンセルボタンをクリックするか、フォームが閉じられたときに設定されるものであれば何でも構いません。