Parallel.For 루프 - 각 스레드에 대한 고유 한 데이터 엔티티 할당

Question

1에서 100까지의 병렬화에 대한 100 개의 레코드가 있습니다. 이제 Parallel.For를 사용하여 Parallel에서 다음과 같이 실행할 수 있습니다. 컴퓨팅 자원

Parallel.For(0, limit, i => 
    { 
     DoWork(i); 
    }); 

있지만 특정 제한이에, 각 스레드는 동일한 데이터 엔티티와 함께 ​​작동하도록해야합니다 및 데이터 엔티티의 수는 제한이 있습니다 서로 복제 및에 저장하여 고급에서 생성되는, 10 말 사전 또는 목록과 같은 구조. 이제 다음 코드를 사용하여 병렬화의 양을 제한 할 수 있습니다

Parallel.For(0, limit, new ParallelOptions { MaxDegreeOfParallelism = 10 }, i => 
    { 
     DoWork(i); 
    }); 

을하지만 문제는 데이터 개체가 실행의 다른 현재의 thread가 사용되지 않도록, 각 수신 스레드에 대한 고유 데이터 엔티티를 할당하는 방법입니다 왜냐하면 스레드와 데이터 엔티티의 수가 동일하기 때문에 기아가 문제가되지 않기 때문입니다. 생각할 수있는 방법은 각 데이터 엔티티에 대해 부울 값을 작성하여 사용 중인지 여부를 지정하므로 사전 또는 목록을 반복하여 사용 가능한 다음 데이터 엔티티를 찾고 전반적인 할당 프로세스를 잠글 수 있습니다. 하나의 스레드는 주어진 시간에 데이터 엔티티를 할당 받지만이 문제는 훨씬 더 세련된 해결책이 될 것입니다. 제 버전은 해결 방법 일뿐 실제 수정 사항이 아닙니다. 내 논리는 다음과 같습니다

Parallel.For(0, limit, new ParallelOptions { MaxDegreeOfParallelism = 10 }, i => 
     { 
      lock(All_Threads_Common_Object) 
      { 
       Check for available data entity using boolean 
       Assign the Data entity 
      } 
      DoWork(i); 

      Reset the Boolean value for another thread to use it 
     }); 

이 문제는 더 해명

Answer 1

concurrent collection을 사용하여 10 개의 개체를 저장할 수 있습니다. 각 Worker는 하나의 데이터 엔티티를 가져 와서 사용하고 돌려줍니다. 시나리오에서 정상적인 것은 스레드로부터 안전하지 않기 때문에 동시 수집을 사용하는 것이 중요합니다. 그래서 같이

:

이

var queue = new ConcurrentQueue<DataEntity>(); 
// fill the queue with 10 items 

Parallel.For(0, limit, new ParallelOptions { MaxDegreeOfParallelism = 10 }, i => 
    { 
     DataEntity x; 
     if(!queue.TryDequeue(out x)) 
      throw new InvalidOperationException(); 
     DoWork(i, x); 
     queue.Enqueue(x); 
    }); 

또는 요구를 차단하는 것이 제공 될 경우 BlockingCollection에서 일을 마무리.

편집 : 을 수행하지 마십시오.을 반복하여 대기 상태로 유지하십시오. 대신 BlockingCollection을 다음과 같이 사용하십시오.

var entities = new BlockingCollection(new ConcurrentQueue<DataEntity>()); 

// fill the collection with 10 items 

Parallel.For(0, limit, new ParallelOptions { MaxDegreeOfParallelism = 10 }, i => 
    { 
     DataEntity x = entities.Take(); 
     DoWork(i, x); 
     entities.Add(x); 
    }); 

Answer 2

를 사용하여 스레드 로컬 초기화 기능을 허용 Parallel.For의 과부하를 필요로하는 경우 알려 주시기 바랍니다.

Parallel.For<DataEntity>(0, limit, 
    //will run once for each thread 
    () => GetThreadLocalDataEntity(), 

    //main loop body, will run once per iteration 
    (i, loop, threadDataEntity) => 
    { 
     DoWork(i, threadDataEntity); 
     return threadDataEntity; //we must return it here to adhere to the Func signature. 
    }, 

    //will run once for each thread after the loop 
    (threadDataEntity) => threadDataEntity.Dispose() //if necessary 
); 

당신이 질문을 게시 한 대이 방법의 가장 큰 장점은, DataEntity의 할당이 루프 반복 당 한번도 스레드에 한 번 발생합니다.