首页 > 代码库 > 生产者和消费者
生产者和消费者
package xianchencaozuo.demo; /* * 生产者和消费者案例 * 问题1:由于多线程的原因,消费者在加入消息名称,还未加入消息内容,就切到了消费者线程,这样会将消息名称和上一个消息的内容 * 加在一起 * 为了解决这个问题,可以使用同步 * */ //信息类,设置信息名,信息内容,获得信息名,信息内容 class Info{ private String infoname; private String infoconnet; public void setinfoname(String infoname){ this.infoname = infoname; } public String getinfoname(){ return infoname; } public void setinfoconnet(String infoconnet){ this.infoconnet = infoconnet; } public String getinfoconnet(){ return infoconnet; } } //生产者类实现runnable class product implements Runnable{ //设置一个标志位 private boolean flag = false; //product构造方法为属相赋值 private Info info = null; public product (Info info){ this.info = info; } public void run(){ for (int i = 0; i < 50; i++) { if (flag) { this.info.setinfoname("sophia "); //在名称 和内容之间加入延迟 try{Thread.sleep(500);} catch(Exception e){ System.out.println(e.getStackTrace()); } this.info.setinfoconnet("欢迎老师"); //修改标志位 flag = false; } else { this.info.setinfoname("测试开发 "); //在名称 和内容之间加入延迟 try{Thread.sleep(500);} catch(Exception e){ System.out.println(e.getStackTrace()); } this.info.setinfoconnet("我要测试开发"); //修改标志位 flag = true; } } } } //消费者类 class consumer implements Runnable{ private Info info = null ; public consumer(Info info){ this.info = info; } public void run(){ for (int i = 0; i <50; i++) { //取信息名称 和信息内容,并加入延迟 System.out.println(this.info.getinfoname()); try{Thread.sleep(500);} catch(Exception e){ System.out.println(e.getStackTrace()); } System.out.println(this.info.getinfoconnet()); } } } //测试类 public class ThreadCaseDemo { public static void main(String[] args) { Info in = new Info(); product pd = new product(in); consumer cs = new consumer(in); new Thread(pd).start(); new Thread(cs).start(); } }
生产者和消费者
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。