Microsoft MVP성태의 닷넷 이야기
글쓴 사람
정성태 (techsharer at outlook.com)
홈페이지
첨부 파일
 

.NET에서 Producer/Consumer를 구현한 BlockingCollection<T>

지난 글에서,

.NET에서 Producer/Consumer를 구현하는 기초 인터페이스 - IProducerConsumerCollection<T>
; https://www.sysnet.pe.kr/2/0/12993

IProducerConsumerCollection<T> 인터페이스를 다뤘는데요, 사실 저 인터페이스만 구현해서는 현실적으로 Producer/Consumer 모델에 사용하기가 좀 번거롭습니다. 가령, 데이터를 생성하는 측면에서 보면 단순히 Concurrent 컬렉션에 값을 넣기만 하면 되므로 그다지 문제가 안 되지만, 데이터를 소비하는 측면에서 보면 언제 데이터가 올지 알 수 없으므로 폴링 방식으로 데이터를 계속 체크하든가, 아니면 signal을 이용해 데이터의 유무를 확인하는 부가 코드를 넣어야 합니다.

바로 그러한 부가 작업을 담당하도록 마이크로소프트가 미리 제공하는 클래스가 BlockingCollection<T>입니다. 사실 이전 글에서 IProducerConsumerCollection을 IConcurrentCollection의 의미로 봐야 한다고 했는데요, 그렇게 따졌을 때 사실상 BlockingCollection이야말로 IProducerConsumerCollection 인터페이스라는 이름을 상속받는 것이 더 어울릴 것입니다.

간단하게 필요한 부분만 내부 구현 방식을 살펴볼까요?

BlockingCollection.cs
; https://referencesource.microsoft.com/#system/sys/system/collections/concurrent/BlockingCollection.cs

BlockingCollection<T>는 이미 thread-safe하게 구현한, 즉 IProducerConsumerCollection<T> 인터페이스를 구현한 타입을 사용해 내부에 필드로 선언해 두고 관련한 작업들은 그것에 맡깁니다. 단지, 추가된 것이라면 SemaphoreSlim을 이용해 해당 자료 구조에서 값을 넣고 빼는 것에 대한 blocking 기능을 제공하는 정도입니다. 즉, 스레드 대기 기능만 추가된 것입니다.

사용자가 명시하지 않은 경우, 기본적으로 BlockingCollection<T>는 (Queue<T>의 thread-safe 버전인) ConcurrentQueue<T>를 사용하기 때문에 FIFO 구조의 Producer/Consumer 동작을 하게 됩니다.

public class BlockingCollection : IEnumerable, ICollection, IDisposable, IReadOnlyCollection
{
    public BlockingCollection() : this(new ConcurrentQueue<T>())
    {
    }

    // ...[생략]...
}

물론, BlockingCollection<T> 생성자에 ConcurrentStack<T>을 전달한다면 FILO 방식으로 동작합니다.

좀 더 자세한 내용은 아래의 글을 확인하시고,

BlockingCollection Overview
; https://docs.microsoft.com/en-us/dotnet/standard/collections/thread-safe/blockingcollection-overview

BlockingCollection 컬렉션 소개
; https://forum.dotnetdev.kr/t/blockingcollection/512

참고로, 예전에 저는 화면 캡처한 것을 Queue에 넣고, 다른 스레드에서 그것을 받아 처리하는 용도로 BlockingCollection을 사용한 적이 있습니다.

C# - OpenCvSharp을 이용한 Webcam 영상 처리 + Direct2D
; https://www.sysnet.pe.kr/2/0/11405

그리고, Win32 메시지도 처리한다는데,

72. Thread.Yield나 Thread.Join은 COM 메시지를 처리할까?
; https://www.sysnet.pe.kr/2/0/11879#72

이것은 BlockingCollection이 사용하는 SemaphoreSlim이 결국 Monitor.Enter 등을 사용하기 때문으로 얻어지는 효과로 보입니다.




[이 글에 대해서 여러분들과 의견을 공유하고 싶습니다. 틀리거나 미흡한 부분 또는 의문 사항이 있으시면 언제든 댓글 남겨주십시오.]

[연관 글]






[최초 등록일: ]
[최종 수정일: 3/8/2022]

Creative Commons License
이 저작물은 크리에이티브 커먼즈 코리아 저작자표시-비영리-변경금지 2.0 대한민국 라이센스에 따라 이용하실 수 있습니다.
by SeongTae Jeong, mailto:techsharer at outlook.com

비밀번호

댓글 작성자
 




1  2  3  [4]  5  6  7  8  9  10  11  12  13  14  15  ...
NoWriterDateCnt.TitleFile(s)
13044정성태5/4/2022368오류 유형: 808. error : clang++ exited with code 127
13043정성태5/3/2022367오류 유형: 807. C# - 닷넷 응용 프로그램에서 Informix DB 사용 시 오류 메시지 정리
13042정성태5/3/2022513.NET Framework: 2000. C# - 닷넷 응용 프로그램에서 Informix DB 사용 방법파일 다운로드1
13041정성태4/28/2022441개발 환경 구성: 642. Informix 데이터베이스 docker 환경 구성
13040정성태4/27/2022475VC++: 156. 비주얼 스튜디오 - Linux C/C++ 프로젝트에서 openssl 링크하는 방법
13039정성태4/27/2022589.NET Framework: 1999. C# - Playwright를 이용한 간단한 브라우저 제어 실습
13038정성태4/26/2022459오류 유형: 806. twine 실행 시 ConfigParser.ParsingError: File contains parsing errors: /root/.pypirc
13037정성태4/25/2022556.NET Framework: 1998. Azure Functions를 사용한 간단한 실습
13036정성태4/24/2022957.NET Framework: 1997. C# - nano 시간을 가져오는 방법 [2]
13035정성태4/22/2022882Windows: 204. Windows 10부터 바뀐 QueryPerformanceFrequency, QueryPerformanceCounter
13034정성태4/21/2022747.NET Framework: 1996. C# XingAPI - 주식 종목에 따른 PBR, PER, ROE, ROA 구하는 방법(t3320, t8430 예제)파일 다운로드1
13033정성태4/18/2022975.NET Framework: 1195. C# - Thread.Yield와 Thread.Sleep(0)의 차이점(?)
13032정성태4/17/2022557오류 유형: 805. Github의 50MB 파일 크기 제한 - warning: GH001: Large files detected. You may want to try Git Large File Storage
13031정성태4/15/2022658.NET Framework: 1194. C# - IdealProcessor와 ProcessorAffinity의 차이점
13030정성태4/15/2022608오류 유형: 804. 정규 표현식 오류 - Quantifier {x,y} following nothing.
13029정성태4/14/2022680Windows: 203. iisreset 후에도 이전에 설정한 전역 환경 변수가 w3wp.exe에 적용되는 문제
13028정성태4/13/2022695.NET Framework: 1193. (appsettings.json처럼) web.config의 Debug/Release에 따른 설정 적용
13027정성태4/12/2022716.NET Framework: 1192. C# - 환경 변수의 변화를 알리는 WM_SETTINGCHANGE Win32 메시지 사용법파일 다운로드1
13026정성태4/11/2022969.NET Framework: 1191. C 언어로 작성된 FFmpeg Examples의 C# 포팅 전체 소스 코드 [1]
13025정성태4/11/2022689.NET Framework: 1190. C# - ffmpeg(FFmpeg.AutoGen)를 이용한 vaapi_encode.c, vaapi_transcode.c 예제 포팅
13024정성태4/7/2022674.NET Framework: 1189. C# - 런타임 환경에 따라 달라진 AppDomain.GetCurrentThreadId 메서드
13023정성태4/6/2022702.NET Framework: 1188. C# - ffmpeg(FFmpeg.AutoGen)를 이용한 transcoding.c 예제 포팅 [3]
13022정성태3/31/2022625Windows: 202. 윈도우 11 업그레이드 - "PC Health Check"를 통과했지만 여전히 업그레이드가 안 되는 경우 해결책
13021정성태3/31/2022720Windows: 201. Windows - INF 파일을 이용한 장치 제거 방법
13020정성태3/30/2022872.NET Framework: 1187. RDP 접속 시 WPF UserControl의 Unloaded 이벤트 발생파일 다운로드1
13019정성태3/30/2022677.NET Framework: 1186. Win32 Message를 Code로부터 메시지 이름 자체를 구하고 싶다면?파일 다운로드1
1  2  3  [4]  5  6  7  8  9  10  11  12  13  14  15  ...