fork download

copy

namespace SukaBlyad
{
    using System;
    using System.Collections.Concurrent;
    using System.Threading;
    using System.Threading.Tasks;
    using Microsoft.Extensions.DependencyInjection;
    using Microsoft.Extensions.Hosting;
    using Microsoft.Extensions.Logging;
 
    public class Program
    {
        public static void Main(string[] args)
        {
            CreateHostBuilder(args).Build().Run();
        }
 
        public static IHostBuilder CreateHostBuilder(string[] args) =>
            Host.CreateDefaultBuilder(args)
                .ConfigureServices((hostContext, services) =>
                {
                    services.AddSingleton<SquareQueue>();
                    services.AddHostedService<SquareWorker>();
                    services.AddHostedService<AddDataWorcker>();
                });
    }
 
    public class SquareWorker : BackgroundService
    {
        private readonly ILogger<SquareQueue> _logger;
        private readonly SquareQueue _queue;
 
        public SquareWorker(ILogger<SquareQueue> logger, SquareQueue queue)
        {
            _logger = logger;
            _queue = queue;
        }
 
        protected override async Task ExecuteAsync(CancellationToken stoppingToken)
        {
            while (!stoppingToken.IsCancellationRequested)
            {
                var data = await _queue.GetData();
                _logger.LogInformation($"Square of {data.Item1} and {data.Item2} = {data.Item1 * data.Item2}");
                await Task.Delay(1000, stoppingToken);
            }
        }
    }
 
    public class SquareQueue
    {
        ILogger<SquareQueue> _logger;
 
        ConcurrentQueue<(double, double)> dataQueue;
        public SquareQueue(ILogger<SquareQueue> logger)
        {
            _logger = logger;
            dataQueue = new ConcurrentQueue<(double, double)>();
        }
 
        public async Task<(double, double)> GetData()
        {
            await Task.Yield();
            if (dataQueue.TryDequeue(out var result))
                return result;
            return (0, 0);
        }
        public async void AddData(double a, double b)
        {
            await Task.Yield();
            dataQueue.Enqueue((a, b));
        }
    }
 
    public class AddDataWorcker : BackgroundService
    {
        private readonly ILogger<SquareQueue> _logger;
        private readonly SquareQueue _queue;
        Random random = new Random();
 
        public AddDataWorcker(ILogger<SquareQueue> logger, SquareQueue queue)
        {
            _logger = logger;
            _queue = queue;
        }
 
        protected override async Task ExecuteAsync(CancellationToken stoppingToken)
        {
            while (!stoppingToken.IsCancellationRequested)
            {
                _queue.AddData(random.NextDouble() + random.Next(100), random.NextDouble() + random.Next(100));
                await Task.Delay(1000, stoppingToken);
            }
        }
    }
 
}
 

prog.cs(7,21): error CS0234: The type or namespace name `Extensions' does not exist in the namespace `Microsoft'. Are you missing an assembly reference?
prog.cs(8,21): error CS0234: The type or namespace name `Extensions' does not exist in the namespace `Microsoft'. Are you missing an assembly reference?
prog.cs(9,21): error CS0234: The type or namespace name `Extensions' does not exist in the namespace `Microsoft'. Are you missing an assembly reference?
prog.cs(28,33): error CS0246: The type or namespace name `BackgroundService' could not be found. Are you missing an assembly reference?
prog.cs(75,35): error CS0246: The type or namespace name `BackgroundService' could not be found. Are you missing an assembly reference?
prog.cs(18,23): error CS0246: The type or namespace name `IHostBuilder' could not be found. Are you missing an assembly reference?
prog.cs(30,26): error CS0246: The type or namespace name `ILogger' could not be found. Are you missing an assembly reference?
prog.cs(33,29): error CS0246: The type or namespace name `ILogger' could not be found. Are you missing an assembly reference?
prog.cs(39,39): error CS0115: `SukaBlyad.SquareWorker.ExecuteAsync(System.Threading.CancellationToken)' is marked as an override but no suitable method found to override
prog.cs(52,9): error CS0246: The type or namespace name `ILogger' could not be found. Are you missing an assembly reference?
prog.cs(55,28): error CS0246: The type or namespace name `ILogger' could not be found. Are you missing an assembly reference?
prog.cs(77,26): error CS0246: The type or namespace name `ILogger' could not be found. Are you missing an assembly reference?
prog.cs(81,31): error CS0246: The type or namespace name `ILogger' could not be found. Are you missing an assembly reference?
prog.cs(87,39): error CS0115: `SukaBlyad.AddDataWorcker.ExecuteAsync(System.Threading.CancellationToken)' is marked as an override but no suitable method found to override
Compilation failed: 14 error(s), 0 warnings

Standard output is empty