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

 找回密码
 加入黑马

QQ登录

只需一步,快速开始

© 云水禅心 中级黑马   /  2013-10-4 19:49  /  953 人查看  /  1 人回复  /   0 人收藏 转载请遵从CC协议 禁止商业使用本文

这是今天的小部分学习小笔记:
消费者生产者的编码,里面有多线程、同步、死锁等知识点。

class ProducerConsumerDemo
{
public static void main(String[] args)
{
  Resource r = new Resource();
  
  Producer pro = new Producer(r);
  Consumer con = new Consumer(r);
  Thread t1 = new Thread(pro);
  Thread t2 = new Thread(pro);
  Thread t3 = new Thread(con);
  Thread t4 = new Thread(con);
  
  t1.start();
  t2.start();
  t3.start();
  t4.start();
  
}
}
class Resource
{
private String name;
private int count = 1;
private boolean flag = false;

public synchronized void set(String name)
{
  while(flag)   //定义while判断标记是因为要让被唤醒的线程再一次判断标记。
   try{this.wait();}catch(Exception e){}
  this.name = name+"--"+count++;
  System.out.println(Thread.currentThread().getName()+"....生产者...."+this.name);
  flag = true;
  this.notifyAll();  //定义notifyAll,即唤醒本方也唤醒对方。如果只有notify就容易出现只唤醒本方线程的情况,导致程序中的所有线程都等待。
}
public synchronized void out()
{
  while(!flag)
   try{wait();}catch(Exception e){}
  System.out.println(Thread.currentThread().getName()+"....消费者..........."+this.name);
  flag = false;
  this.notifyAll();
}
}
class Producer implements Runnable
{
private Resource res;

Producer(Resource res)
{
  this.res = res;
}
public void run()
{
  while(true)
  {
   res.set("商品");
  }
}
}
class Consumer implements Runnable
{
private Resource res;

Consumer(Resource res)
{
  this.res = res;
}
public void run()
{
  while(true)
  {
   res.out();
  }
}
}

评分

参与人数 1技术分 +1 收起 理由
乔兵 + 1

查看全部评分

1 个回复

倒序浏览
感谢分享
回复 使用道具 举报
您需要登录后才可以回帖 登录 | 加入黑马