sender.java

一个很好的JAVA聊天室系统 可以在课堂里实践并且进行聊天

class RingBuffer    // 加互斥锁的环形缓冲区
{
    static int MAXSIZE = 6;
    private int[] rb = new int[10];
    private int head = MAXSIZE-1, tail = MAXSIZE-1;

    synchronized private boolean rbfull() {
       if (((tail+1) % MAXSIZE) == head) return true;
       else return false;
    }
    synchronized private boolean rbempty() {
       if (tail == head) return true;
       else return false;
    }

    synchronized void put(int i)
    {
        while (rbfull())       // 当环形缓冲区满时,等待
        {
            try
            {
                 this.wait();              
            }
            catch(InterruptedException e)
            {
                 System.out.println(e.getMessage());
            }
        }
        rb[(++tail) % MAXSIZE] = i;
        notify();              // 唤醒其他等待线程
    }
    synchronized int get()
    {
        while (rbempty())      // 当环形缓冲区空时,等待
        { 
            try
            {
                 this.wait();
            }
            catch(InterruptedException e)
            {
                 System.out.println(e.getMessage());
            }
        }        
        notify();
        return rb[(++head) % MAXSIZE];                      
    }
}

class Sender extends Thread {   // 发送线程
    private RingBuffer bf;
    public Sender(RingBuffer bf)
    {
        this.bf = bf;
    }
    public void run( )
    {
        for (int i=1;i<10;i++)
        {
            bf.put( i );
            System.out.println("Sender  put : " + i );
        }
    }
    public static void main (String args[])
    {
        RingBuffer bf = new RingBuffer();
        (new Sender(bf)).start();
        (new Receiver(bf)).start();
    }
}
class Receiver extends Thread {   // 接受线程
    private RingBuffer bf;
    public Receiver(RingBuffer bf)
    {
        this.bf = bf ;
    }
    public void run()
    {
        for (int i=1; i<10;i++)
            System.out.println("\t\t     Receiver get : " + bf.get()) ;
    }
}