packageorg.lx.multithreading ;classInfo//定义信息类{privateString name="罗星";//定义name属性privateString content="JAVA初学者";//定义content属性privatebooleanflag=false;//设置标志位publicsynchronizedvoidset(String name, String content){if(!flag){//方法每次执行的时候都检查一下标志位状态，从而判断时候进行生产try{super.wait() ;

}catch(InterruptedException e){

e.printStackTrace() ;

}

}this.setName(name) ;//设置名称try{

Thread.sleep(300) ;

}catch(InterruptedException e){

e.printStackTrace() ;

}this.setContent(content) ;//设置内容flag=false;//改变标志位,表示可以取走super.notify() ;//唤醒线程}publicsynchronizedvoidget(){if(flag){方法每次执行的时候都检查一下标志位状态，从而判断时候进行取出try{super.wait() ;

}catch(InterruptedException e){

e.printStackTrace() ;

}

}try{

Thread.sleep(300) ;

}catch(InterruptedException e){

e.printStackTrace() ;

}

System.out.println(this.getName()+"-->"+this.getContent()) ;

flag=true;//改变标志位,表示可以生成super.notify() ;

}publicvoidsetName(String name){this.name=name ;

}publicString getName(){returnthis.name ;

}publicvoidsetContent(String content){this.content=content ;

}publicString getContent(){returnthis.content ;

}

}classProducerimplementsRunnable//通过Runnable实现多线程{publicInfo info=null;//保存Info引用publicProducer(Info info){this.info=info ;

}publicvoidrun(){booleanflag=false;//定义标记位for(inti=0; i<50; i++){if(flag){this.info.set("罗星","JAVA初学者") ;

flag=false;

}else{this.info.set("Solitary","Coder") ;

flag=true;

}

}

}

} ;classConsumerimplementsRunnable{//消费者类privateInfo info=null;publicConsumer(Info info){this.info=info ;

}publicvoidrun(){for(inti=0; i<50; i++){this.info.get() ;

}

}

} ;//测试代码publicclassMultiThreading

{publicstaticvoidmain(String[] args){

Info info=newInfo() ;//实例化Info对象Producer pro=newProducer(info) ;//生产者Consumer con=newConsumer(info) ;//消费者newThread(pro).start() ;newThread(con).start() ;

}

}