生产者消费者JAVA队列实现

class SyncQueue...{
    private int head=0;//队头
    private int tail=1;//队尾
    public final int Num=6;//缓冲区大小
    public char data[]=new char[Num];
    public  synchronized void inqueue(char c)...{
        while((tail+1)%Num==head)...{
            try...{
                this.wait();
            }catch(InterruptedException e)...{System.out.println(e);}
            
        }
        this.notify();
        
            data[tail]=c;
            tail=(tail+1)%Num;
            System.out.println("produced:" + c );
        
        
    }
    public  synchronized char outqueue()...{
        while((head+1)%Num==tail)...{
            try...{
                this.wait();
            }catch(InterruptedException e)...{System.out.println(e);}
        }
            this.notify();
        
    
            head=(head+1)%Num;
            
            System.out.println("消费："+data[head]);
            return data[head];
        
    
    }
}

class Producer implements Runnable...{
    SyncQueue queue;
    public Producer(SyncQueue s)...{
        queue=s;
    }
    public void run()...{
        for(int i=0;i<20;i++)...{
            char c=(char)(Math.random()*26+'A');
            queue.inqueue(c);
            try...{
                Thread.sleep((int)(Math.random()*20));
            }catch(InterruptedException e)...{System.out.println(e);}
        }
    }
}

class Customer implements Runnable...{
    SyncQueue queue;
    public Customer(SyncQueue s)...{
        queue=s;
    }
    public void run()...{
        for(int i=0;i<20;i++)...{
            char c=queue.outqueue();
            try...{
                Thread.sleep((int)(Math.random()*20));
            }catch(InterruptedException e)...{System.out.println(e);}
        }
    }
}

public class SyncTest...{
    public static void main (String[] args) ...{
        SyncQueue queue=new SyncQueue();
        Runnable p=new Producer(queue);
        Runnable c=new Customer(queue);
        Thread t1=new Thread(p);
        Thread t2=new Thread(c);
        t1.start();
        t2.start();
        
    }
}

注：注意wait()和notify()的位置，否则将引者死锁的发生。

评论

1 楼 aoly80 2009-07-28  

能给点注释吗