------<a href="http://www.itheima.com" target="blank">Java培训、Android培训、iOS培训、.Net培训</a>、期待与您交流！ -------

public static void main(String[] args) {// tongbu i=new tongbu();//创建抽取出来的同步方法对象hjw j=new hjw(i);//创建实现Runnable接口的对象bb k=new bb(i);Thread xc1 =new Thread(j);//创建线程Thread xc2 =new Thread(k);xc1.setName("生产者");xc2.setName("消费者");xc1.start();xc2.start();}}
class tongbu{//将两个同步方法抽取出来private String name;private int count=1;boolean flag=false;//定义一个bool类型来作用等待唤醒机制public synchronized void set(String name){//生产者的同步函数if(flag){//已存在就睡眠try{wait();}catch(Exception e){}}//否则 运作代码this.name=name+"---"+count++;System.out.println(Thread.currentThread().getName()+this.name);flag=true;//改变bool值this.notify();//唤醒线程}public synchronized void get(){if(!flag){//进入休眠try{wait();}catch(Exception e){}}//被生产者唤醒System.out.println(Thread.currentThread().getName()+"---"+this.name);flag=false;this.notify();//唤醒线程}
}
class hjw implements Runnable{private tongbu x ;hjw(tongbu x){//传回tongbu对象this.x=x;}public void run(){//重写run方法while(true){x.set("饼干");}}
}
class bb implements Runnable{private tongbu x ;bb(tongbu x){//传回tongbu对象this.x=x;}public void run(){//重写run方法while(true){x.get();}}
}

public static void main(String[] args) {// tongbu i=new tongbu();//创建抽取出来的同步方法对象hjw j=new hjw(i);//创建实现Runnable接口的对象bb k=new bb(i);Thread xc1 =new Thread(j);//创建线程Thread xc2 =new Thread(k);xc1.setName("生产者");xc2.setName("消费者");xc1.start();xc2.start();}}
class tongbu{//将两个同步方法抽取出来private String name;private int count=1;boolean flag=false;//定义一个bool类型来作用等待唤醒机制public synchronized void set(String name){//生产者的同步函数while(flag){//已存在就睡眠try{wait();}catch(Exception e){}}//否则 运作代码this.name=name+"---"+count++;System.out.println(Thread.currentThread().getName()+this.name);flag=true;//改变bool值this.notifyAll();//唤醒线程}public synchronized void get(){while(!flag){//进入休眠try{wait();}catch(Exception e){}}//被生产者唤醒System.out.println(Thread.currentThread().getName()+"---"+this.name);flag=false;this.notifyAll();//唤醒线程}
}
class hjw implements Runnable{private tongbu x ;hjw(tongbu x){//传回tongbu对象this.x=x;}public void run(){//重写run方法while(true){x.set("饼干");}}
}
class bb implements Runnable{private tongbu x ;bb(tongbu x){//传回tongbu对象this.x=x;}public void run(){//重写run方法while(true){x.get();}}
}