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

Question

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

Answer 1

ActionBlock의 바인드되지 않은 용량이 BufferBlock의 제한된 용량과 상관없는 경우 ActionBlock은 메모리가 부족할 때까지 모든 항목을 버퍼링합니다. 그러나 ActionBlock의 BoundedCapcity을 2로 설정하고 MaxDegreeParallelism을 2로 설정하면 두 개의 메시지를 처리하고 두 개의 메시지를 버퍼에 보관합니다. 그런 다음 버퍼 블록은 2 개의 추가 메시지를 버퍼링합니다. 추가 메시지는 파이프 라인에서 용량을 기다려야합니다. 공간을 확보 할 때까지 기다리는 가장 좋은 방법은 await myPipeline.SendAsync(data)입니다. 합계로 전체 파이프 라인에 대해 6의 용량을 갖습니다.