buffertest.cs

jsp+javabean+servlet实现的在线书店

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

namespace IM
{
    public class BufferTest
    {
        int n=0;
        volatile bool running = true;
        BoundedBuffer buffer = new BoundedBuffer();
        public void run()
        {            
            Thread t1 = new Thread(this.putThread);
            Thread t2 = new Thread(this.takeThread);
            t1.Start();
            t2.Start();
            t1.Join();
            t2.Join();
        }
        public void putThread()
        {
            while (running)
            {
                buffer.put(n++);
                if (n > 100)
                    running = false;
            }
        }
        public void takeThread()
        {
            while (running)
            {
                buffer.take();
            }
        }
    }
}