System.Threading.Channels onUued kogutüübid, mis tutvustati pärast .NET Core 3.0 versiooniSeda saab kasutada sõnumite järjekorrastamiseks, andmete tootmiseks ja tarbimiseks ning avalikud kirjutaja ja lugeja API-d vastavad sõnumite tootjatele ja tarbijatele, mis muudab kanali ka lühikesemaks ja lihtsamaks kasutada.
System.Threading.Channels raamatukogu:Hüperlingi sisselogimine on nähtav. <T> Kanaliklass:Hüperlingi sisselogimine on nähtav.
Kanalitüüp
Microsoft pakub kahte tüüpi kanaleid: üks on piiratud mahutavusega seotud kanal ja teine piiramatu mahutavusega.
Loo kanal piiratud mahutavusega:Channel.CreateBounded<string>(100);
Loo kanal, millel on piiramatu mahutavus:Channel.CreateUnbounded<string>();
Loo piiramatult kanaleid
Kanali loomisel saad määrata ChannelOptionsi SingleWriteri ja SingleReaderi määrama ühe tootja ja tarbija, kui kanal on seatud fale'iks, kui SingleWriter = true on seatud, piirab see ainult ühe tootja andmestikku samaaegselt, SingleReader = true on sama.
Proovi avada kolm tootjalõime ja üks tarbijalõim järgmise koodiga:
Tarbija kasutab WaitToReadAsync'i, et oodata andmete lugemist. Tarbijad püüavad andmeid lugeda alles siis, kui need on kättesaadavad.
Ülaltoodud koodis loevad tarbijad andmeid ükshaaval, et teha operatsioone, kuidas neid tehaHulgitarbimise andmedMis saab töötlemisest?
Loo uus ChannelReaderExtensions laiend järgmise koodiga:
Kohandage tarbijakoodi järgmiselt:
(Lõpp)
|