using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;

namespace ProducentKonsument
{
    class Program
    {
        static int licznik = 0;
        static readonly int liczbaWatkow = 10;
        static readonly int liczbaIteracji = 10;
        static readonly object locking = new object();

        static EventWaitHandle pisanie = new ManualResetEvent(true);
        static EventWaitHandle czytanie = new ManualResetEvent(false);

        static void Main(string[] args)
        {
            List<Thread> watkiKonsument = new List<Thread>();
            //Random rand = new Random(); //random wspólny
            for (int i = 0; i < liczbaWatkow; i++)
            {
                var konsument = new Thread(() =>
                {
                    //Random rand = new Random(); //random lokalny seed oparty na czasie
                    Random rand = new Random(Thread.CurrentThread.ManagedThreadId); //random lokalny seed oparty na Id wątku

                    for (int j = 0; j < liczbaIteracji; j++)
                    {

                        var czasUspienia = rand.Next(1000);
                            Console.Write("{0} ", czasUspienia);
                            Console.WriteLine("[{0}] ", licznik);
                        lock (locking)
                        {
                            czytanie.WaitOne();
                            czytanie.Reset();
                        }
                        pisanie.Set();
                        Thread.Sleep(czasUspienia);
                    }
                });
                watkiKonsument.Add(konsument);
                konsument.Start();
            }

            Thread watekProducent = new Thread(() =>
            {
                Random randPiszacy = new Random(Thread.CurrentThread.ManagedThreadId);
                try
                {
                    while (true)
                    {
                        pisanie.WaitOne();
                        pisanie.Reset();
                        Interlocked.Increment(ref licznik);
                        czytanie.Set();
                        Thread.Sleep(randPiszacy.Next(100));
                    }
                }
                catch (ThreadInterruptedException)
                {
                    Console.WriteLine("\nWątek piszący został zakończony");
                }
            });

            watekProducent.Start();

            foreach (var watek in watkiKonsument)
            {
                watek.Join();
            }

            watekProducent.Interrupt();
            watekProducent.Join();

            Console.WriteLine("To już jest koniec, naciśnij ENTER...");
            Console.ReadLine();
        }
    }
}