/
aprogrammer
/
dotnet-docs
Обзор
Документация
Войти
/
aprogrammer
/
dotnet-docs
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
main
docs/core/extensions/snippets/channels/Program.Bounded.cs
43 строки
1 KB
David Pine
`System.Threading.Channels` in .NET (#30462)
04 авг 2022, 17:10
Не верифицирован
04 авг 2022, 17:10
27db9b4
Код
Авторство
О чём код?
internal static partial class Program { internal static Channel<Coordinates> CreateBounded() { // <boundedcapcity> var channel = Channel.CreateBounded<Coordinates>(1); // </boundedcapcity> return channel; } internal static Channel<Coordinates> CreateBoundedWithOptions() { // <boundedoptions> var channel = Channel.CreateBounded<Coordinates>( new BoundedChannelOptions(1_000) { SingleWriter = true, SingleReader = false, AllowSynchronousContinuations = false, FullMode = BoundedChannelFullMode.DropWrite }); // </boundedoptions> return channel; } internal static Channel<Coordinates> CreateBoundedWithOptionsAndCallback() { // <boundedcallback> var channel = Channel.CreateBounded( new BoundedChannelOptions(10) { AllowSynchronousContinuations = true, FullMode = BoundedChannelFullMode.DropOldest }, static void (Coordinates dropped) => Console.WriteLine($"Coordinates dropped: {dropped}")); // </boundedcallback> return channel; } }