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

namespace MulThead
{
    class signel
    {
        public Semaphore singleRead;
        public Semaphore singleWrite;
        public Semaphore singleMutex;
        private int size;

        public signel(int size)
        {
            this.size = size;
            singleRead = new Semaphore(0,size);         //一共size個(gè)read資源，目前有0個(gè)可用
            singleWrite = new Semaphore(size, size);    //一共size個(gè)write資源，目前有size個(gè)可用
            singleMutex = new Semaphore(1, 1);
        }
    }
    class Reader
    {
        private signel sgl;
        private Queue<int> que;
        private Form1 f1;
        //保存信號(hào)量和隊(duì)列的一個(gè)引用
        public Reader(signel sgl, Queue<int> que,Form1 f1)
        {
            this.sgl = sgl;
            this.que = que;
            this.f1 = f1;
        }
        public void Process()
        {
            int readvalue;
            while(true)
            {
                sgl.singleRead.WaitOne();
                sgl.singleMutex.WaitOne();
                readvalue = que.Dequeue();
                f1.txtReader.Text += readvalue.ToString();
                f1.txtReader.Text += " ";
                sgl.singleMutex.Release();
                sgl.singleWrite.Release();     //釋放寫資源
            }
        }
       
    }
    class Writer
    {
        private signel sgl;
        private Queue<int> que;
        private Form1 f1;

        public Writer(signel sgl, Queue<int> que,Form1 f1)
        {
            this.sgl = sgl;
            this.que = que;
            this.f1 = f1;
        }
        public void Process()
        {

            int i = 0;
            while(i < 50)
            {
                i++;
                sgl.singleWrite.WaitOne();
                sgl.singleMutex.WaitOne();
                f1.txtWriter.Text += i.ToString();
                f1.txtWriter.Text += " ";
                que.Enqueue(i);
                sgl.singleMutex.Release();
                sgl.singleRead.Release();         //釋放讀資源
            }
        }

    }
}






        private void Form1_Load(object sender, EventArgs e)
        {
            CheckForIllegalCrossThreadCalls = false;  //這樣在不是創(chuàng)建該控件（此form里的控件）的線程里也可以用這個(gè)控件了
            //信號(hào)量
            signel sgl = new signel(10);

            //新建一個(gè)隊(duì)列緩沖區(qū)
            Queue<int> que = new Queue<int>(10);
            Reader readerThread = new Reader(sgl,que,this);
            Writer writerThread = new Writer(sgl,que,this);
            //開啟兩個(gè)線程
            Thread tRead = new Thread(readerThread.Process);
            Thread tWrite= new Thread(writerThread.Process);
            tRead.Start();
            tWrite.Start();
        }