A股上市公司传智教育(股票代码 003032)旗下技术交流社区北京昌平校区

 找回密码
 加入黑马

QQ登录

只需一步,快速开始

© Без_тебя 中级黑马   /  2014-6-22 12:31  /  1063 人查看  /  0 人回复  /   0 人收藏 转载请遵从CC协议 禁止商业使用本文

生产者消费者模式,就是说生产者在生产的时候,消费者休息,生产者停止生产了,消费者将就来消费,等消费者消费完后,消费者休息,生产者起来继续生场
我建了四个类模拟

测试类
public class Test {
        public static void main(String[] args) {
                Movie m = new Movie();
                Watcher w = new Watcher(m);
                Player p = new Player(m);
                Thread t1 = new Thread(w);
                Thread t2 = new Thread(p);
               
                t1.start();
                t2.start();
        }
}


//导演类
public class Player implements Runnable {
        private Movie m;
        public Player(Movie m){
                this.m = m;
        }
        @Override
        public void run() {
                for(int i =0;i<=20;i++){
                        if(i%2==0){
                                m.play("蜘蛛侠");
                        }else{
                                m.play("钢铁侠");
                        }
                }
        }
}


//观众类
public class Watcher implements Runnable {
        private Movie m;
        public Watcher(Movie m){
                this.m = m;
        }
        @Override
        public void run() {
                for(int i=0;i<=20;i++){
                        m.watch();
                }
        }
}


//电影类
public class Movie {
        private boolean flag=true;
        private String pic;
        public void play(String pic){
                synchronized (this) {
                        if(!flag){
                                try {
                                        this.wait();
                                } catch (InterruptedException e) {
                                        // TODO Auto-generated catch block
                                        e.printStackTrace();
                                }
                        }
                        try {
                                Thread.sleep(500);
                        } catch (InterruptedException e) {
                                // TODO Auto-generated catch block
                                e.printStackTrace();
                        }
                        this.pic=pic;
                        System.out.println("生产了:"+this.pic);
                        this.notify();
                        this.flag=!flag;
                }
        }
        public void watch(){
                synchronized (this) {
                        if(flag){
                                try {
                                        this.wait();
                                } catch (InterruptedException e) {
                                        // TODO Auto-generated catch block
                                        e.printStackTrace();
                                }
                        }
                        try {
                                Thread.sleep(500);
                        } catch (InterruptedException e) {
                                // TODO Auto-generated catch block
                                e.printStackTrace();
                        }
                        System.out.println("在看:"+this.pic);
                        this.notifyAll();
                        this.flag=!flag;
                }
        }
}


0 个回复

您需要登录后才可以回帖 登录 | 加入黑马