Program.cs

using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.Reflection.Metadata;
using System.Threading.Tasks;

namespace AsyncProcessing
{
    class Rekord
    {
        public int ID { get; set; }
        public int wartosc {  get; set; }
        public string operacja { get; set; }
        public int proby { get; set; } = 0;
    }

    class SharedState
    {
        public int Value { get; set; }
        public int pominiete { get; set; } = 0;
    }

    class Program()
    {
        static async Task Main()
        {
            var stan = new SharedState() { Value = 0 };
            var kolejka = new ConcurrentQueue<Rekord>();

            Console.WriteLine("podaj wielkosc zbioru");

            if(!int.TryParse(Console.ReadLine(), out int wielkoscZbioru) || wielkoscZbioru <=0) {
                Console.WriteLine("zla liczba");
                return;
            }

            var rand = new Random();
            string[] operacje = { "dodawanie", "odejmowanie" };

            for(int i = 0; i < wielkoscZbioru; i++)
            {
                kolejka.Enqueue(new Rekord
                {
                    ID = i,
                    wartosc = rand.Next(0, 10),
                    operacja = operacje[rand.Next(0, 2)]
                });
            }

            Task t1 = operuj(kolejka, stan);
            Task t2 = operuj(kolejka, stan);
            Task t3 = operuj(kolejka, stan);

            Task.WaitAll(t1,t2,t3);

            Console.WriteLine($"koniec, stan: {stan.Value}");
            Console.WriteLine($"pominiete: {stan.pominiete}");
        }

        private static readonly object lockKey = new object();

        static async Task operuj(ConcurrentQueue<Rekord> kolejka, SharedState stanWspolny)
        {
            var rand = new Random();
            while(kolejka.TryDequeue(out Rekord rekord))
            {
                try
                {
                    if(rand.Next(0, 100) <= 20)
                    {
                        throw new Exception("blad");
                    }
                    if(rand.Next(0,100) <= 10)
                    {
                        stanWspolny.pominiete++;
                        continue;
                    }
                    lock (lockKey)
                    {
                        if (rekord.operacja == "dodawanie")
                        {
                            stanWspolny.Value += rekord.wartosc;
                        }
                        else if (rekord.operacja == "odejmowanie")
                        {
                            stanWspolny.Value -= rekord.wartosc;
                        }
                    }
                    Console.WriteLine($"id: {rekord.ID}, wartosc: {rekord.wartosc}, operacja: {rekord.operacja}, stan po operacji: {stanWspolny.Value}");
                }
                catch (Exception ex)
                {
                    rekord.proby++;
                    if(rekord.proby<3)
                    {
                        kolejka.Enqueue(rekord);
                    }
                    else
                    {
                        stanWspolny.pominiete++;
                    }
                }
            }
        }
    }
}