내가 병렬 처리해야하는 특정 항목의 일정한 흐름을 가지고 있으므로 TPL Dataflow을 사용하고 있습니다. catch와 같은 키를 공유하는 항목 (사전과 유사)은 FIFO 순서로 처리되어야하며 서로 평행하지 않아야합니다 (서로 다른 값을 가진 다른 항목과 병렬이 될 수 있음). 작업이 진행되고 내 솔루션은 더 병렬 처리 Environment.Proces
저는 4 개의 블록 (하나의 선택적 블록 포함)으로 구성된 응용 프로그램에서 HTTP를 통해 쿼리 개체를 받고 데이터베이스에서 정보를 검색하고 선택적인 작업을 수행하는 Dataflow 파이프 라인을 만들었습니다 해당 데이터를 변환 한 다음 HTTP 응답에 정보를 다시 쓰십시오. 일부 테스트에서는 데이터베이스 (570,000 행)의 상당량의 데이터를 가져 와
2 가지 다른 소스에서 오는 2 가지 다른 데이터가 있는데 두 가지 다른 주파수에서 데이터가 합쳐져서 함께 처리해야한다고 가정 해 봅시다. 채널 A의 주파수는 100Hz (초당 100 정수)이며 채널 B의 주파수는 1Hz (초당 1 정수)입니다. 데이터는 TPL 데이터 흐름에서 ActionBlock을 사용하여 각 개별 채널에서 이미 처리됩니다. 이제는 함께
좋은 하루.이 출력 흐름 : BlockBuffer 출력을 를 저장하는 나는 RPC 그것은 다음과 같습니다 단순화 된 방법으로 두 unkinked 흐름을 가지고 를 호출하기위한 TPL 데이터 흐름 메쉬가 서버로 출력을 보내고 전송 된 ID를 생성하는 ActionBlock 서버 그리고 입력 흐름 : 루프는 문제가 sentid 과 대답을 저장하는 데이터를 데이터
티저 :이 질문은 재시도 정책을 구현하는 방법이 아닙니다. 이는 TPL Dataflow 블록을 올바르게 완료 한 것입니다. 이 질문은 대부분 내 이전 질문 Retry policy within ITargetBlock의 연속입니다. 이 질문에 대한 답은 TransformBlock (소스) 및 TransformManyBlock (대상)을 사용하는 @ svick의
나는 느린 코드를 실행하고 잊어 버릴 ASP.WEB 웹 API 컨트롤러가 있습니다. 그렇게하는 좋은 방법은 무엇입니까? 즉 컨트롤러가 HTML 응답을 브라우저에 반환하고 느린 코드는 계속 실행되도록합니다. 트레드 풀에서 작업자 스레드를 가져 와서 컨트롤러로 만든 복잡한 객체를 전달하는 것이 좋은가요? 또는 작업을 수행하기 위해 별도의 Windows 서비스를
MaxDegreeOfParallelism이 1인데도 병렬 처리가 발생하는 것으로 보이는 ActionBlock에 게시 할 때 예기치 않은 동작이 나타납니다. ActionBlock에 게시물이 같다고 클래스 :이 public class ByteHandler {
...
public ByteHandler(ByteHandlingCallback delegat
내가 이해하는 한, TPL Dataflow는 .NET 프로그래머 용 Actor 프로그래밍 모델을 제공합니다 (이전에 사용 가능했던 타사 솔루션에 대해서는 언급하지 않았습니다). 액터 모델 자체는 각 액터가 지원할 수있는 세 가지 기본 작동 인 '전송', '생성'및 '생성'이 있음을 선언합니다. TPL Dataflow에서 '될'의미를 다루는 '올바른'방법은
TPL DataFlow부터 시작하겠습니다. 다음 작업 코드가 생성되었습니다. public async void ReadItems(ITargetBlock<SourceCodeFile> target)
{
foreach(var item in Source)
{
await target.SendAsync(item); //when To use
작업 병렬 라이브러리를 사용하여 다음과 같은 동작을 시도하고 있습니다 : 메시지가 도착하면서 순차적으로 처리하지만 그룹으로 처리하고 싶습니다. 따라서 첫 번째 메시지가 도착하면 즉시 처리해야합니다. 첫 번째는 후 처리되는 동안이 메시지가 올 경우 그들은 내가 거의 내가 BatchBlock가 ActionBlock var batchBlock = new Batc