Microsoft MVP성태의 닷넷 이야기
.NET Framework: 1173. .NET에서 Producer/Consumer를 구현한 BlockingCollection<T> [링크 복사], [링크+제목 복사],
조회: 11798
글쓴 사람
정성태 (techsharer at outlook.com)
홈페이지
첨부 파일
 
(연관된 글이 1개 있습니다.)
(시리즈 글이 4개 있습니다.)
.NET Framework: 209. AutoReset, ManualReset, Monitor.Wait의 차이
; https://www.sysnet.pe.kr/2/0/1015

.NET Framework: 1120. C# - BufferBlock<T> 사용 예제
; https://www.sysnet.pe.kr/2/0/12845

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

.NET Framework: 1173. .NET에서 Producer/Consumer를 구현한 BlockingCollection<T>
; https://www.sysnet.pe.kr/2/0/12995




.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<T> : IEnumerable<T>, ICollection, IDisposable, IReadOnlyCollection<T>
{
    public BlockingCollection() : this(new ConcurrentQueue<T>())
    {
    }

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

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

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

BlockingCollection Overview
; https://learn.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

// 기타 사용 예제
SingleThreadTaskScheduler에서 사용한 예제
; https://www.sysnet.pe.kr/2/0/13188#SingleThreadTaskScheduler

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

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

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




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

[연관 글]






[최초 등록일: ]
[최종 수정일: 12/10/2022]

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

비밀번호

댓글 작성자
 




... 61  62  63  64  65  66  [67]  68  69  70  71  72  73  74  75  ...
NoWriterDateCnt.TitleFile(s)
12135정성태2/6/202017374개발 환경 구성: 468. Nuget 패키지의 로컬 보관 폴더를 옮기는 방법 [2]
12134정성태2/5/202016733.NET Framework: 884. eBEST XingAPI의 C# 래퍼 버전 - XingAPINet Nuget 패키지 [5]파일 다운로드1
12133정성태2/5/202014003디버깅 기술: 161. Windbg 환경에서 확인해 본 .NET 메서드 JIT 컴파일 전과 후 - 두 번째 이야기
12132정성태1/28/202016870.NET Framework: 883. C#으로 구현하는 Win32 API 후킹(예: Sleep 호출 가로채기) [1]파일 다운로드1
12131정성태1/27/202015823개발 환경 구성: 467. LocaleEmulator를 이용해 유니코드를 지원하지 않는(한글이 깨지는) 프로그램을 실행하는 방법 [1]
12130정성태1/26/202013058VS.NET IDE: 142. Visual Studio에서 windbg의 "Open Executable..."처럼 EXE를 직접 열어 디버깅을 시작하는 방법
12129정성태1/26/202018720.NET Framework: 882. C# - 키움 Open API+ 사용 시 Registry 등록 없이 KHOpenAPI.ocx 사용하는 방법 [3]
12128정성태1/26/202013465오류 유형: 591. The code execution cannot proceed because mfc100.dll was not found. Reinstalling the program may fix this problem.
12127정성태1/25/202013297.NET Framework: 881. C# DLL에서 제공하는 Win32 export 함수의 내부 동작 방식(VT Fix up Table)파일 다운로드1
12126정성태1/25/202014399.NET Framework: 880. C# - PE 파일로부터 IMAGE_COR20_HEADER 및 VTableFixups 테이블 분석파일 다운로드1
12125정성태1/24/202011745VS.NET IDE: 141. IDE0019 - Use pattern matching
12124정성태1/23/202013588VS.NET IDE: 140. IDE1006 - Naming rule violation: These words must begin with upper case characters: ...
12123정성태1/23/202015394웹: 39. Google Analytics - gtag 함수를 이용해 페이지 URL 수정 및 별도의 이벤트 생성 방법 [2]
12122정성태1/20/202011796.NET Framework: 879. C/C++의 UNREFERENCED_PARAMETER 매크로를 C#에서 우회하는 방법(IDE0060 - Remove unused parameter '...')파일 다운로드1
12121정성태1/20/202012699VS.NET IDE: 139. Visual Studio - Error List: "Could not find schema information for the ..."파일 다운로드1
12120정성태1/19/202014356.NET Framework: 878. C# DLL에서 Win32 C/C++처럼 dllexport 함수를 제공하는 방법 - 네 번째 이야기(IL 코드로 직접 구현)파일 다운로드1
12119정성태1/17/202014523디버깅 기술: 160. Windbg 확장 DLL 만들기 (3) - C#으로 만드는 방법
12118정성태1/17/202015200개발 환경 구성: 466. C# DLL에서 Win32 C/C++처럼 dllexport 함수를 제공하는 방법 - 세 번째 이야기 [1]
12117정성태1/15/202014096디버깅 기술: 159. C# - 디버깅 중인 프로세스를 강제로 다른 디버거에서 연결하는 방법파일 다운로드1
12116정성태1/15/202014598디버깅 기술: 158. Visual Studio로 디버깅 시 sos.dll 확장 명령어를 (비롯한 windbg의 다양한 기능을) 수행하는 방법
12115정성태1/14/202015085디버깅 기술: 157. C# - PEB.ProcessHeap을 이용해 디버깅 중인지 확인하는 방법파일 다운로드1
12114정성태1/13/202017038디버깅 기술: 156. C# - PDB 파일로부터 심벌(Symbol) 및 타입(Type) 정보 열거 [1]파일 다운로드3
12113정성태1/12/202016814오류 유형: 590. Visual C++ 빌드 오류 - fatal error LNK1104: cannot open file 'atls.lib' [1]
12112정성태1/12/202013074오류 유형: 589. PowerShell - 원격 Invoke-Command 실행 시 "WinRM cannot complete the operation" 오류 발생
12111정성태1/12/202016639디버깅 기술: 155. C# - KernelMemoryIO 드라이버를 이용해 실행 프로그램을 숨기는 방법(DKOM: Direct Kernel Object Modification) [16]파일 다운로드1
12110정성태1/11/202015313디버깅 기술: 154. Patch Guard로 인해 블루 스크린(BSOD)가 발생하는 사례 [5]파일 다운로드1
... 61  62  63  64  65  66  [67]  68  69  70  71  72  73  74  75  ...