<T> BlockingCollection .GetConsumingEnumerable()의 추가 조건

Question

에 차단 그것은 모두에서 GetConsumingEnumerable() 스트림 및 일부 다른 기준에 (예 내에서 JobQueue) BlockingCollection<T> 블록 실행이 가능한가?

사용 가능한 슬롯이있을 때만 항목을 소비 할 수있는 상태 인 availableSlots > 0이 있습니다. 문제는 컬렉션에 항목이 있지만 조건이 거짓 일 때 foreach가 무기한 반복된다는 것입니다.

컬렉션을 availableSlots > 0에서도 차단하지 못합니까?

foreach (var job in JobQueue.GetConsumingEnumerable()) 
{ 
    if(availableSlots > 0) 
    { 
     JobHandler jobHandler = job; 

     Task.Factory.StartNew(() => 
     { 
      ExecuteJob(jobHandler); 
     }); 
    } 
} 

아마도이 모음을 잘못 사용하고 있습니다. 어떤 도움을 주셔서 감사합니다!

Answer 1

값이 0 인 동안 차단하려는 경우 추가 동기화가 필요합니다. 그것은 정확하게 당신이 필요로 않기 때문에 나는 당신을위한 적합한 솔루션이 SemaphoreSlim 생각 : 대기 그 값이 그와 0

동안, 같이 보일 것입니다 코드 :

SemaphoreSlim slotsSemaphore = new SemaphoreSlim(…); 

… 

foreach (var job in JobQueue.GetConsumingEnumerable()) 
{ 
    slotsSemaphore.Wait(); 

    JobHandler jobHandler = job; 

    Task.Factory.StartNew(() => 
    { 
     try 
     { 
      ExecuteJob(jobHandler); 
     } 
     finally 
     { 
      slotsSemaphore.Release(); 
     } 
    }); 
} 

Answer 2

이것이 최선의 방법인지는 모르겠지만 제 선택의 폭을 넓 힙니다.

사실 일 때까지 기다리지 않으시겠습니까?

while (availableSlots <= 0) 
{ 
    Thread.Sleep(1);//arbitary sleep 
} 

JobHandler jobHandler = job; 
... 

또는 사용 SpinWait

SpinWait.SpinUntil(() => availableSlots > 0); 

JobHandler jobHandler = job; 
... 

세 번째 옵션은 ManualResetEvent 또는 AutoResetEvent

signal.Waitone(); 

JobHandler jobHandler = job; 
... 

를 사용하고 availableSlots의 값을 변경할 때 signal을 설정하는 것입니다.