线程间通信一小例学习

wait:告诉线程放弃监视器并进入睡眠状态,直到其他线程进入同一监视器并调用notify为止
notify:唤醒同一对象监视器中调用wait的第一个线程,用于类似饭馆有一个空位后通知所有等候就餐顾客中的第一位可以入座的情况.
notifyAll:唤醒同一对象监视器中调用wait的所有线程,具有最高优先级的线程首先被唤醒并执行.

看下面的步骤:
Thread t --> synchronized(o)--->o.wait()--->o.notify
1、新建一个线程t
2、线程t得到对象o的lock旗标
3、此时线程t被放置在对象o的等待线程池中,t自动释放o的锁旗标
4、当另外的线程执行了对象o的notify()方法后,线程t可能会被从o的等待线程池中释放出来,并且移动到等待线程对象o的锁旗标的线程池中,当t得到锁旗标时就会执行下去

下面是一个经典的消费者-生产者的线程间访问的代码举例

生产者的类如下：

class Producer implements Runnable
{
  Q q;
  public Producer(Q q)
  {
    this.q = q;
  }
  public void run()
   {
    int i = 0;
    while(true)
     {
       if(i == 0 )  
              q.put("zhangsan","male");
       else 
              q.put("lisi","female");
       i = (i+1)%2;
     }
   }
}

消费者的类如下：

class Consumer implements Runnable
{
  Q q;
  public Consumer(Q q)
  {
    this.q = q;
  }
  public void run()
   {
      while(true)
     { 
      q.get();
     }
   }
}

下面是用户信息的类，最经典的用法，各类有各类应该的职责,put()与get()方法写得很不错，值得学习

class Q 
{ 
  private String name="unknown";
  private String sex = "unknown";
  private boolean bFull = false;
  public synchronized void put(String name,String sex)
  {
    if(bFull)  
           try{wait();} catch(Exception e){}
    this.name = name;
    try{Thread.sleep(1);} catch(Exception e){}
    this.sex = sex;
    bFull = true;
    notify();
  }
  public synchronized void get()
  {
        if(!bFull)
                try{ wait(); }catch(Exception e){}
        System.out.print(name);
        System.out.println(":" +sex); 
        bFull = false;
        notify();
  }
}

简单的运行类如下：

public class ThreadCommuncation
{
   public static void main(String[] args)
   {
      Q q = new Q();
     new Thread(new Producer(q)).start();
     new Thread(new Consumer(q)).start();
   }
}

注明：文中所有的代码均为[张孝祥JAVA视频教程中的代码，并非我本人所写，我记录下来，只是复习一下线程间的一些关键点的地方.

评论

5 楼 lighter 2007-06-25  

使用wait()方法的时候,有可能抛出异常,在java里必须强制你要捕捉可能出现的异常(其实有两种异常的)

4 楼 xombat 2007-06-25  

if(bFull)        
     wait();  

抱歉这个理解错误，
为了防止因为抛出异常而产生的操作中断，是这样吧。

3 楼 xombat 2007-06-24  

排版弄乱了，抱歉将就看吧

2 楼 xombat 2007-06-24  

呵呵，把博客当成笔记本用了--同时也分享了知识。
我用c实现过生产者和消费者模型，涉及到互斥量，多线程的那些东东。
认真看了看你的代码，感觉就是两个线程操作一块共享区域，无所谓通信吧，通信是对于进程来说的。

    if(bFull)     
           [color=red]try{wait();} catch(Exception e){} [/color]

对这块代码有点不解，为什么不直接这样写呢？

    if(bFull)     
         wait(); 

java不怎么懂，语言不是隔阂，期望讨论。

1 楼 lighter 2007-06-21  

http://blog.hry.cn/article.asp?id=998
java多线程同步设计wait/notify机制
这一篇文章也挺不错的