docs/core/extensions/snippets/channels/Program.Producer.cs - main - aprogrammer/dotnet-docs

docs/core/extensions/snippets/channels/Program.Producer.cs

65 строк2 KB

David Pine

`System.Threading.Channels` in .NET (#30462)

04 авг 2022, 17:10

04 авг 2022, 17:1027db9b4

internal static partial class Program
{
    // <whiletrywrite>
    static void ProduceWithWhileAndTryWrite(
        ChannelWriter<Coordinates> writer, Coordinates coordinates)
    {
        while (coordinates is { Latitude: < 90, Longitude: < 180 })
        {
            var tempCoordinates = coordinates with
            {
                Latitude = coordinates.Latitude + .5,
                Longitude = coordinates.Longitude + 1
            };

            if (writer.TryWrite(item: tempCoordinates))
            {
                coordinates = tempCoordinates;
            }
        }
    }
    // </whiletrywrite>

    // <whilewrite>
    static async ValueTask ProduceWithWhileWriteAsync(
        ChannelWriter<Coordinates> writer, Coordinates coordinates)
    {
        while (coordinates is { Latitude: < 90, Longitude: < 180 })
        {
            await writer.WriteAsync(
                item: coordinates = coordinates with
                {
                    Latitude = coordinates.Latitude + .5,
                    Longitude = coordinates.Longitude + 1
                });
        }

        writer.Complete();
    }
    // </whilewrite>

    // <waittowrite>
    static async ValueTask ProduceWithWaitToWriteAsync(
        ChannelWriter<Coordinates> writer, Coordinates coordinates)
    {
        while (coordinates is { Latitude: < 90, Longitude: < 180 } &&
            await writer.WaitToWriteAsync())
        {
            var tempCoordinates = coordinates with
            {
                Latitude = coordinates.Latitude + .5,
                Longitude = coordinates.Longitude + 1
            };

            if (writer.TryWrite(item: tempCoordinates))
            {
                coordinates = tempCoordinates;
            }

            await Task.Delay(TimeSpan.FromMilliseconds(10));
        }

        writer.Complete();
    }
    // </waittowrite>
}