TPL 데이터 흐름 메시지 유형 할당 패턴이 가능합니까?

Question

다른 유형의 out-of-process 메시지를받는 알고리즘을 실행합니다. 들어오는 메시지는 실제로 바이트 배열이고 각 바이트 배열은 메시지 유형을 나타내는 바이트 배열 플래그에 의해 미리 보류됩니다. 들어오는 바이트 배열을 처리하는 IPropagator<byte[], byte[]>을 설정하고 바이트 배열 플래그를 해석 한 다음 바이트 배열을 연결된 해당 ActionBlock에 스트리밍하도록 설정할 수 있는지를 알고 싶습니다.

예를 들어, 내가 2 개의 다른 메시지 유형을 갖고 있고, 2 개의 서로 다른 ActionBlocks가 수신해야하는 메시지 유형과 일치하는 메시지 만 수신한다고 가정 해 보겠습니다. 두 액션 블록에 IPropagatorBlock을 연결하면 둘 다 ActionBlocks가 같은 메시지를 받겠습니까? 플래그에 따라 각 메시지를 올바르게 할당하려면 어떻게해야합니까 (플래그에 대해 걱정할 필요가 없습니다. 식별은 쉽지 않습니다. 언제든지 ActionBlock IPropgatorBlock이 메시지를 스트리밍하려고합니다). 데이터 흐름 구조를 올바르게 설정하는 데 어려움을 겪고 있습니다. Post()하는 대신 데이터 블록을 서로 직접 연결할 수 있기를 바랍니다. 그게 가능하니?

그 점에 대해 도움을 주시면 감사하겠습니다.

Answer 1

이것은 사용중인 IPropagatorBlock에 따라 다릅니다. 사용자 지정 항목 인 경우 링크 된 순서 (또는 더 안정적인 항목)에 따라 사용할 대상 블록을 인식하는 등의 작업을 수행 할 수 있습니다.

그러나 블록을 가정하는 것은 실제로 정상 TransformBlock (또는 같은), 나는 최선의 선택이 the overload of LinkTo() that takes a predicate을 사용하는 것입니다 생각하고 IPropagatorBlock<byte[], Tuple<FlagType, byte[]>>에 블록의 유형을 변경하는 것을 의미한다 (출력 유형에 플래그를 추가, 또는 Tuple 대신 사용자 정의 유형). 이를 수행하면 해당 대상에 대한 술어가 메시지와 일치하는 경우에만 대상이 메시지를 수신하게됩니다.

원본 블록에 따라 하나의 원본 블록을 다른 대상 블록에 연결하면 어떻게됩니까? 대부분의 경우 각 메시지를 정확하게 하나의 대상으로 보냅니다. 첫 번째 대상을 먼저 시도하고 첫 번째 대상이 거부되거나 메시지를 연기하는 경우 두 번째 대상을 시도합니다. 이 규칙의 예외는 항상 BroadcastBlock (및 이와 유사한 WriteOnceBlock)이며 모든 메시지를 항상 모든 대상으로 보내려고합니다. 다시 한 번, 사용자 정의 블록은 원하는대로 작동 할 수 있습니다.