tpl-dataflow

4열

1답변

내 응용 프로그램에서 여러 문자열을 대체 값 사전으로 조인하려고합니다. readTemplateBlock은 FileInfos와 함께 제공되고 그 내용을 문자열로 반환합니다. getReplacersBlock은 하나의 대체 단어 사전으로 피드됩니다 (한 번). joinTemplateAndReplacersBlock은 readTemplateBlock의 각 항목에 하

2열

1답변

데이터 흐름을위한 블록 디자인에서 차단됨

우리는 TPL Dataflow 프레임 워크를 사용하려고하는 데이터 처리 파이프 라인을 가지고 있습니다. 파이프 라인의 기본 요점 : 파일 시스템에 CSV 파일을 통해 반복 처리가 (10,000) 우리는 하나의 콘텐츠를 통해 반복 처리를 무시할 경우 우리가 내용을 가져 오지 않은 확인 CSV 파일 (20,000-120,000 행)을 만들고 필요에 맞는 데이터

4열

1답변

반응 프로그래밍을 사용하여 FileStream을 열어 쓰기 위해 작성

작은 로거를 작성 중이며 로그 파일을 한 번 열어서 로그 메시지가 도착하면 응답을 계속 작성하고 프로그램 종료시 모든 내용을 처리하려고합니다. FileStream을 열린 상태로 유지할 수있는 방법이 확실하지 않습니다. 및 메시지가 도착하면 반응적으로 작성합니다. 큐를 사용하는 using 문 내부의 루프와 버퍼로 동작하는 ConcurrentQueue가있는 이

1열

1답변

TPL DataFlow가 ActionBlock에서 예외를 처리 할 수 없음

ActionBlock<int>에서 ActionBlock<int> 인 여러 소비자에게 하나의 메시지 사본을 보내려고합니다. 이것은 잘 작동하지만 대상 블록 중 하나가 예외를 throw하면 소스 블록에 전파되지 않는 것으로 보입니다. 여기에서 나는 예외를 처리하려고하지만 결코 catch 부분에 간다 방법 : 나는 예외를 가져 오지 수있는 것은 내가 여기없는거야

0열

1답변

TPL BufferBlock 호출 메서드 호출되지 않음

질문 : here 및 코드 here과 연속적으로 실행되는 BufferBlock을 사용하여 소비자/제작자 패턴을 구현하고 싶습니다. OP와 마찬가지로 ActionBlock을 사용하려고했지만 버퍼 블록이 가득 차고 새 메시지가 대기열에 있으면 새 메시지가 ConcurrentDictionary _queue에 추가되지 않습니다. 새 메시지가이 호출로 bufferb

1열

1답변

TPL DataFlow가 데이터 흐름을 두 번 호출합니다.

다양한 DataBlock로 구성된 복잡한 데이터 흐름을 설계했습니다. 나는 흐름으로 패킷을 보내고 끝에 결과를 받는다. 나는 모두가 잘 작동 첫 번째 전화를 들어 input.Post(); input.Complete(); // and later with ReceiveAsync(); 와 함께 작동,하지만 난 흐름 그래프로를 통해 두 번째 데이터 패킷

3열

1답변

예외 처리 기능을 사용하여 끝이없는 DataFlow 메쉬를 만드는 방법은 무엇입니까?

TPL DataFlow를 사용하는 Task 프로세서를 만들고 있습니다. 나는 프로듀서 소비자 모델을 따를 것이며, 프로듀서는 한 번에 처리 할 아이템을 생산하고 소비자는 새로운 아이템이 도착하기를 기다리고있다. 여기 내 코드는 다음과 같습니다 async Task Main() { var runner = new Runner(); Cancel

1열

1답변

ActionBlock이 시작되거나 끝날 때 항목이 BufferBlock에서 제거됩니까?

BufferBlock에 2의 제한된 용량이 있고 이것을 (LinkTo()을 사용하여) MaxBegreeOfParallelism = 2 인 ActionBlock과 링크한다고 가정 해 봅시다. 이제 바로 2 개의 항목을 버퍼에 보낼 수 있고 ActionBlock은 즉시 처리를 시작하십시오. 하지만 작업을 완료하는 데 몇 초가 걸린다고 가정 해 보겠습니다. 버퍼

1열

1답변

TPL-Dataflow에서 집계 및 조인 (내부, 외부, 왼쪽, ...)?

BatchBlock을 사용하여 완료 될 때까지 모든 항목을 버퍼링하고 컬렉션으로 내 보낸 다음 변환 블록을 사용하여 실제 집계를 수행하는 것보다 TPL - Dataflow 메시에서 집계와 같은 기능을 구현하는 더 좋은 방법이 있습니까? 비슷하게 BatchedJoinBlock을 사용하지 않고 두 데이터 세트의 내부/외부/왼쪽/오른쪽 조인을 수행하는 다른 방법

0열

1답변

TPL 라운드 로빈 링크가있는 블록?

TPL을 많이 사용하고 있으며 큰 데이터 흐름 파이프 라인 구조를 가지고 있습니다. 파이프 라인 네트워크의 일부로 푸른 색 얼룩 저장 장치에 일부 데이터를 쓰려고합니다. 우리는 많은 데이터를 가지고 있으므로 4 스토리지 계정이 있고 그 사이에 데이터를 균등하게 분배하려고합니다. 데이터 흐름 파이프 라인 패턴을 계속 사용하고자하므로 SourceBlock을 구