java 与操作系统进程同步问题（二）————经典消费者生产者问题

     /**
     * 代表缓冲区是否空
     */
    Semaphore empty;
    
    /**
     * 代表缓冲区是否满
     */
    Semaphore full;

wait(empty)

//放入产品


signal(full)

wait(full)


//取产品


signal(empty)

public class ProductAndVistor {
    Thread producer = new Thread(new Runnable() {
        
        @Override
        public void run() {
            String className = "producer";
            // TODO Auto-generated method stub
            while(true) {
                Semaphore.Wait(empty, className);
                System.out.println(className + "往缓冲区放了一个产品");
                //随机生成休眠时间，代表放入产品的操作时间
                long millis = (long) (Math.random() * 1000);
                try {
                    Thread.sleep(millis);
                } catch (InterruptedException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                Semaphore.Signal(full, className);
            }
            
        }
        
    });
    
    Thread vistor = new Thread(new Runnable() {
        String className = "vistor";
        @Override
        public void run() {
            // TODO Auto-generated method stub
            while(true) {
                Semaphore.Wait(full, className);
                System.out.println(className + "从缓冲区取了一个产品");
                long millis = (long) (Math.random() * 1000);
                try {
                    Thread.sleep(millis);
                } catch (InterruptedException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                Semaphore.Signal(empty, className);
            }
        }
    });
    
    /**
     * 代表缓冲区是否满
     */
    Semaphore empty;
    
    /**
     * 代表缓冲区是否空
     */
    Semaphore full;
    
    public ProductAndVistor(Semaphore s1, Semaphore s2) {
        this.empty = s1;
        this.full = s2;
    }
    
    public ProductAndVistor() {
        empty = new Semaphore(1);
        full = new Semaphore(0);
    }
    
    public void start() {
        producer.start();
        vistor.start();
    }
    
}