.NET 코어 고성능 큐 채널이 사용됩니다

작은 쓰레기 같은 놈들 · 게시됨 2023. 5. 8. 오후 10:11:01

System.Threading.Channels는.NET Core 3.0 이후 도입된 새로운 컬렉션 유형메시지 대기열, 데이터 생성 및 소비에 사용할 수 있으며, 공개 작성자 및 리더 API는 메시지의 생성자와 소비자에 대응하여 채널을 더 간결하고 사용하기 쉽게 만듭니다.

.NET/C#은 BlockingCollection 백그라운드 작업 큐를 기반으로 합니다
https://www.itsvse.com/thread-9528-1-1.html

System.Threading.Channels 라이브러리:하이퍼링크 로그인이 보입니다.
채널<T> 클래스:하이퍼링크 로그인이 보입니다.

채널 유형

마이크로소프트는 두 가지 유형의 채널을 제공합니다. 하나는 용량이 제한된 바운드 채널이고, 다른 하나는 무제한 용량을 가진 언바운드 채널입니다.

용량이 제한된 채널을 만드세요:채널.크리에이트바운드<string>(100);
무제한 용량의 채널을 생성하세요:Channel.CreateUnbounded<string>();

무제한 채널 생성

채널을 생성할 때, ChannelOptions의 SingleWriter와 SingleReader를 설정하여 채널이 false로 설정되었을 때 단일 생산자와 소비자를 지정할 수 있습니다. SingleWriter = true가 설정되면 한 명의 생산자만 동시에 데이터를 쓰는 것이 제한되며, SingleReader = true도 동일합니다.

다음 코드로 세 개의 프로듀서 스레드와 하나의 컨퍼먼스 스레드를 열어보세요:

로그인이 보이네요.

소비자는 데이터가 읽힐 때까지 WaitToReadAsync를 사용합니다. 소비자는 데이터가 공개된 후에야 읽으려 합니다.

위 코드에서 소비자는 데이터를 하나씩 읽어 작업을 수행하고, 어떻게 만들었는지대량 소비자 소비 데이터가공 과정은 어때?

다음 코드로 새로운 ChannelReaderExtensions 확장 프로그램을 생성하세요:

로그인이 보이네요.

소비자 코드를 다음과 같이 조정하세요:

로그인이 보이네요.

(끝)

날치자리 · 게시됨 2023. 5. 8. 오후 10:50:27

배우기 위해 배우세요

ZGY0209ZGY · 게시됨 2023. 5. 12. 오전 10:07:46

배우기 위해 배우세요

추위밍 · 게시됨 2023. 5. 16. 오후 5:21:37

배우기 위해 배우세요

[출처] .NET 코어 고성능 큐 채널이 사용됩니다

관련 게시물

본 섹션