내 최근 질문에 설명 된 기능을 제공하기 위해 자체 PLinq 확장 방법을 고려하고 있습니다 : Specify task timeout in parallel linq to objects. PLinq 쿼리에서 이미 병렬 처리 수준을 지정하고있는 코드를 포함하여 가능한 많은 기존 .Net 구조를 재사용하고 싶습니다. 아래 코드 블록에서 병렬 처리 정도를 지정하고
들어오는 일괄 처리를 처리해야하는 응용 프로그램을 구현했습니다. 예를 들어 특정 객체 유형의 요청 세트가 특정 웹 서비스에 전송되어 처리되어야합니다. 다음 스 니펫을 구현했습니다. var options = new ParallelOptions { MaxDegreeOfParallelism = 10 };
Parallel.ForEach(request, opti
PLINQ를 배우고 있습니다. 나는 사이트에서 주어진 예제를 시도했다. 그러나 나는 결과가 잘못되었다는 것을 알 수 있으며 여러 번 프로그램을 다시 실행할 때도 달라집니다. 먼저 모든 소수를 제공하지 않으며 초당 9591 개의 무작위 소수를 제공합니다. IEnumerable<int> numbers = Enumerable.Range (3, 100000-3);
내 시스템의 구성이되는 논리 프로세서 : 인텔 (R) 코어 (TM) i7-3820QM CPU에서 @의 2.70GHz, 2694 MHz의 4 코어 (들) (8)의 논리 프로세서 (들) 내 컴퓨터에는 4 개의 코어와 8 개의 논리 프로세서가 있습니다. 나는 병렬 처리를 위해 PLINQ 쿼리를 사용하는거야 경우 , 나는 WithDegreeOfParallelism
I가 큰 데이터 세트를 반복하는 방법을 가지고 직렬화 소비자 스레드에 처리 결과를 반환. 스트리밍 PLinq는 최상의 성능을 발휘합니다. 이러한 작업은 빈번 때문에, 전 오브젝트 생성을 최소화하기 위해, 제 처리 용기를 캐시하는 objectpool를 사용하고있다. 나는 concurrentspack (concurrentbag 및 concurrentqueue
최근 Linq와 Plinq에 대해 몇 가지 조치를 취했습니다. 어떤 상황에서 Plinq의 중요한 이점이 있는지 알 수 없습니다. 나는 등 많은 예제를 발견했습니다 Enumerable.Range(0, 10000).AsParallel().ForAll(_ => Thread.Sleep(50000));
가 10000 정도 parallized 될 수 있으며, 예
함수에서 나는 인자로 제공되는 IEnumerable의 병렬 처리를하고 싶습니다. 이 IEnumerable을 이미 일부 체인의 즉의 결과 : IEnumerable argument = InitialEnumerable.Select(x => DoHeavyProcessing(x))...
이다 그러나 나에게이 불투명입니다 -이 인수가 생성되는 방법을 수정할 수 없
는 병렬 실행 모드에서 실행이 경우 Select에 source.AsParallel().Where(expensiveOperation).Select(cheapOperation)
내 생각과 같은 LINQ 쿼리를 가정합니다. 어쩌면 그것은 i => i*2과 같은 값싼 연산 일 수 있습니다. 따라서 연결된 메소드로 질의하는 지점에서 병렬 실행을 중단하는 방법이
나는 AsSequential과 AsOrdered의 차이점에 대해 머리를 감싸고있는 것처럼 보일 수 없다. 나는 예제를 위해 인터넷 검색뿐만 아니라 각각의 msdn에 대한 문서를 찾았지만, 나는 단순한 구두 수선공 일 뿐이며 무엇이 진행되고 있는지 명확히 이해할 수 없었다. 가능한 경우 누군가 AsSequential 대 AsOrdered를 사용할 때 설명해