JAVA学习网首页 把生活查询网加入收藏 把JAVA学习网设为首页 联系方式
    Hi,JAVA学习
JAVA基础 设计模式 数据库 JavaBeans J2EE JavaDelphi 用户界面 综合文章  
Java Thread Programming 1.8.2 - Inter-thread Communication
时间:22/04/2007
作者：网络
来源：网络
小提示→点这里把文章加入您的收藏夹,方便下次查看
设置文章字体大小：[大 中 小]
Missed Notification
 
A missed notification occurs when threadB tries to notify threadA, but threadA is not yet waiting for the notification. In a multithreaded environment like Java, you don’t have much control over which thread runs and for how long. This uncertainty can lead to a situation in which most of the time an application is run, threadA is waiting before threadB does the notification. But occasionally, threadB does the notification before threadA is waiting. This missed notification scenario can be quite dangerous.
 
Missed Notification指：线程B试图通知线程A，但线程A并没有在等待通知。这并不是不可能出现的。在多线程环境中，我们不能控制哪个线程执行，执行多长时间，这种不确定有可能导致在一个线程等待之前就先行通知，这是一种很危险的情况。如下程序会出现这种情况：
 
/*
 * Created on 2005-7-14
 *
 * Java Thread Programming - Paul Hyde
 * Copyright ? 1999 Sams Publishing
 * Jonathan Q. Bo 学习笔记
 *
 */
package org.tju.msnrl.jonathan.thread.chapter8;
 
/**
 * @author Jonathan Q. Bo from TJU MSNRL
 *
 * Email:jonathan.q.bo@gmail.com
 * Blog:blog.csdn.net/jonathan_q_bo
 *      blog.yesky.net/jonathanundersun
 *
 * Enjoy Life with Sun!
 *
 */
public class MissedNotify {
   
    private Object proceedLock;
   
    public MissedNotify(){
       
        proceedLock = new Object();
    }
   
    public void waitProceed() throws InterruptedException{
        print("in waitProceed() - begin");
       
        synchronized(proceedLock){
            print("begin synchronized wait ...");
            proceedLock.wait();
            print("end synchronized wait ...");
        }
       
        print("in waitProceed() - end");
    }
   
    public void notifyProceed(){
        print("in notifyProceed() - begin");
       
        synchronized(proceedLock){
            print("begin synchronized notify ...");
            proceedLock.notifyAll();
            print("end synchronized notify ...");
        }
       
        print("in notifyProceed() - end");
    }
   
    public static void print(String msg){
        String temp = Thread.currentThread().getName();
        System.out.println(temp + " - " + msg);
    }
 
    public static void main(String[] args) {
        final MissedNotify mn = new MissedNotify();
       
        Runnable runA = new Runnable(){
            public void run(){
                try{
                    Thread.sleep(1000);//wait()后执行
                    mn.waitProceed();
                }catch(InterruptedException e){
                    e.printStackTrace();
                }
            }
        };
       
        Thread threadA= new Thread(runA,"threadA");
        threadA.start();
       
        Runnable runB = new Runnable(){
            public void run(){
                try{
                    Thread.sleep(500);//notify()先执行
                    mn.notifyProceed();
                }catch(InterruptedException e){
                    e.printStackTrace();
                }
            }
        };
       
        Thread threadB = new Thread(runB,"threadB");
        threadB.start();
       
        try{
            Thread.sleep(10000);
        }catch(InterruptedException e){
           
        }
       
        print("interrupt thread A ...");
        threadA.interrupt();
    }
}
 
输出结果：
threadB - in notifyProceed() - begin
threadB - begin synchronized notify ...
threadB - end synchronized notify ...
threadB - in notifyProceed() - end
threadA - in waitProceed() - begin
threadA - begin synchronized wait ...
main - interrupt thread A ...
java.lang.InterruptedException
     at java.lang.Object.wait(Native Method)
     at java.lang.Object.wait(Object.java:429)
     at org.tju.msnrl.jonathan.thread.chapter8.MissedNotify.waitProceed(MissedNotify.java:35)
     at org.tju.msnrl.jonathan.thread.chapter8.MissedNotify$1.run(MissedNotify.java:66)
     at java.lang.Thread.run(Thread.java:534)
 
 
解决方法：只需加一个标志位：
 
/*
 * Created on 2005-7-14
 *
 * Java Thread Programming - Paul Hyde
 * Copyright ? 1999 Sams Publishing
 * Jonathan Q. Bo 学习笔记
 *
 */
package org.tju.msnrl.jonathan.thread.chapter8;
 
/**
 * @author Jonathan Q. Bo from TJU MSNRL
 *
 * Email:jonathan.q.bo@gmail.com
 * Blog:blog.csdn.net/jonathan_q_bo
 *      blog.yesky.net/jonathanundersun
 *
 * Enjoy Life with Sun!
 *
 */
public class MissedNotifyFix {
   
    private Object proceedLock;
    private boolean okToProceed;
   
    public MissedNotifyFix(){
        okToProceed = false;
        proceedLock = new Object();
    }
   
    public void waitProceed() throws InterruptedException{
        print("in waitProceed() - begin");
       
        synchronized(proceedLock){
            while(!okToProceed){
                print("begin synchronized wait ...");
                proceedLock.wait();
                print("end synchronized wait ...");
            }
        }
       
        print("in waitProceed() - end");
    }
   
    public void notifyProceed(){
        print("in notifyProceed() - begin");
       
        synchronized(proceedLock){
            okToProceed = true;
            print("begin synchronized notify ...");
            proceedLock.notifyAll();
            print("end synchronized notify ...");
        }
       
        print("in notifyProceed() - end");
    }
   
    public static void print(String msg){
        String temp = Thread.currentThread().getName();
        System.out.println(temp + " - " + msg);
    }
 
    public static void main(String[] args) {
        final MissedNotifyFix mn = new MissedNotifyFix();
       
        Runnable runA = new Runnable(){
            public void run(){
                try{
                    Thread.sleep(1000);
                    mn.waitProceed();
                }catch(InterruptedException e){
                    e.printStackTrace();
                }
            }
        };
       
        Thread threadA= new Thread(runA,"threadA");
        threadA.start();
       
        Runnable runB = new Runnable(){
            public void run(){
                try{
                    Thread.sleep(500);
                    mn.notifyProceed();
                }catch(InterruptedException e){
                    e.printStackTrace();
                }
            }
        };
       
        Thread threadB = new Thread(runB,"threadB");
        threadB.start();
       
        try{
            Thread.sleep(10000);
        }catch(InterruptedException e){
           
        }
       
        print("interrupt thread A ...");
        threadA.interrupt();
    }
}
 
输出结果：
threadB - in notifyProceed() - begin
threadB - begin synchronized notify ...
threadB - end synchronized notify ...
threadB - in notifyProceed() - end
threadA - in waitProceed() - begin
threadA - in waitProceed() - end
main - interrupt thread A ...
 
Early Notification
 
If a thread is notified while waiting, but the condition the thread is waiting for has not yet been met, the thread has received an early notification. An early notification can also occur if the condition is briefly met but quickly changes so it’s no longer met. This might sound strange, but early notification can happen due to subtle errors in the code (generally when an if is used instead of a while).
 
Early notification是指：当一个等待线程被通知的时候，它等待的条件不再满足，这时我们说，线程收到了一个early notification。Early notification在等待的条件瞬间满足然后立刻改变不再满足时，也会发生。通常在一个需要使用while的地方使用了if。
 
Early notification的代码：
/*
 * Created on 2005-7-14
 *
 * Java Thread Programming - Paul Hyde
 * Copyright ? 1999 Sams Publishing
 * Jonathan Q. Bo 学习笔记
 *
 */
package org.tju.msnrl.jonathan.thread.chapter8;
 
import java.util.*;
 
/**
 * @author Jonathan Q. Bo from TJU MSNRL
 *
 * Email:jonathan.q.bo@gmail.com
 * Blog:blog.csdn.net/jonathan_q_bo
 *      blog.yesky.net/jonathanundersun
 *
 * Enjoy Life with Sun!
 *
 */
public class EarlyNotify {
   
    private List list;
   
    public EarlyNotify(){
        list = Collections.synchronizedList(new LinkedList());
    }
   
    public String removeItem() throws InterruptedException{
        print("entering removeItem()...");
        synchronized(list){
            if(list.isEmpty()){
                print("list wait ... begin");
                list.wait();
                print("list wait ... end");
            }
           
            String item = (String)list.remove(0);
           
            print("leaveing removeItem() ...");
            return "you remove " + item;
        }
    }
   
    public void addItem(String item){
        print("entering addItem() ...");
        
        synchronized(list){
            list.add(item);
           
            print("list notify ... begin");
            list.notifyAll();
            print("list notify ... end");
        }
       
        print("leave addItem() ...");
    }
   
    public static void print(String msg){
        String temp = Thread.currentThread().getName();
        System.out.println(temp + " - " + msg);
    }
 
    public static void main(String[] args) {
        final EarlyNotify en = new EarlyNotify();
       
        Runnable runA = new Runnable(){
            public void run(){
                try{
                    String item = en.removeItem();
                    print("in run() remove item " + item);
                }catch(InterruptedException e1){
                    print("interrupted");
                }catch(Exception e2){
                    print("exception" + e2.getMessage());
                }              
            }
        };
       
        Runnable runB = new Runnable(){
            public void run(){
                en.addItem("hello");
            }
        };
       
        try{
            Thread threadA = new Thread(runA,"threadA");
            threadA.start();
           
            Thread.sleep(500);
           
            Thread threadB = new Thread(runA,"threadB");
            threadB.start();
           
            Thread.sleep(500);
           
            Thread threadC = new Thread(runB,"threadC");
            threadC.start();
           
            Thread.sleep(10000);
            threadA.interrupt();
            threadB.interrupt();
           
        }catch(InterruptedException e1){
           
        }catch(Exception e2){
           
        }
       
    }
}
 
输出结果：
threadA - entering removeItem()...
threadA - list wait ... begin
threadB - entering removeItem()...
threadB - list wait ... begin
threadC - entering addItem() ...
threadC - list notify ... begin
threadC - list notify ... end
threadA - list wait ... end
threadA - leaveing removeItem() ...
threadA - in run() remove item you remove hello
threadB - list wait ... end
threadC - leave addItem() ...
threadB - exceptionIndex: 0, Size: 0
 
正确的代码：
/*
 * Created on 2005-7-14
 *
 * Java Thread Programming - Paul Hyde
 * Copyright ? 1999 Sams Publishing
 * Jonathan Q. Bo 学习笔记
 *
 */
package org.tju.msnrl.jonathan.thread.chapter8;
 
import java.util.*;
 
/**
 * @author Jonathan Q. Bo from TJU MSNRL
 *
 * Email:jonathan.q.bo@gmail.com
 * Blog:blog.csdn.net/jonathan_q_bo
 *      blog.yesky.net/jonathanundersun
 *
 * Enjoy Life with Sun!
 *
 */
public class EarlyNotifyFix {
   
    private List list;
   
    public EarlyNotifyFix(){
        list = Collections.synchronizedList(new LinkedList());
    }
   
    public String removeItem() throws InterruptedException{
        print("entering removeItem()...");
        synchronized(list){
            while(list.isEmpty()){//use while instead of if
                print("list wait ... begin");
                list.wait();
                print("list wait ... end");
            }
           
            String item = (String)list.remove(0);
           
            print("leaveing removeItem() ...");
            return "you remove " + item;
        }
    }
   
    public void addItem(String item){
        print("entering addItem() ...");
       
        synchronized(list){
            list.add(item);
           
            print("list notify ... begin");
            list.notifyAll();
            print("list notify ... end");
        }
       
        print("leave addItem() ...");
    }
   
    public static void print(String msg){
        String temp = Thread.currentThread().getName();
        System.out.println(temp + " - " + msg);
    }
 
    public static void main(String[] args) {
        final EarlyNotifyFix en = new EarlyNotifyFix();
       
        Runnable runA = new Runnable(){
            public void run(){
                try{
                    String item = en.removeItem();
                    print("in run() remove item " + item);
                }catch(InterruptedException e1){
                    print("interrupted");
                }catch(Exception e2){
                    print("exception" + e2.getMessage());
                }              
            }
        };
       
        Runnable runB = new Runnable(){
            public void run(){
                en.addItem("hello");
            }
        };
       
        try{
            Thread threadA = new Thread(runA,"threadA");
            threadA.start();
           
            Thread.sleep(500);
           
            Thread threadB = new Thread(runA,"threadB");
            threadB.start();
           
            Thread.sleep(500);
           
            Thread threadC = new Thread(runB,"threadC");
            threadC.start();
           
            Thread.sleep(10000);
            threadA.interrupt();
            threadB.interrupt();
           
        }catch(InterruptedException e1){
           
        }catch(Exception e2){
            
        }
       
    }
}
 
输出结果：
threadA - entering removeItem()...
threadA - list wait ... begin
threadB - entering removeItem()...
threadB - list wait ... begin
threadC - entering addItem() ...
threadC - list notify ... begin
threadC - list notify ... end
threadA - list wait ... end
threadA - leaveing removeItem() ...
threadA - in run() remove item you remove hello
threadB - list wait ... end
threadB - list wait ... begin
threadC - leave addItem() ...
threadB - interrupted
 

上一篇：使用J2WTK2.2编译和运行第一个J2ME的HelloWorld程序

下一篇：Java Thread Programming 1.8.2 - Inter-thread Communication

  • Tomcat5.0配置servlet
  • Eclipse SDK 3.1来了
  • JavaCard开发教程之规范
  • 一片把SWT批判的体无完肤的文章
  • Jbuilder快捷键
  • 用Web Services开发一个决策支持系统
  • 用数据库JDBC连接写法
  • 优秀的O-R Mapping工具－－TOPLink使用简介
  • 新手入门经典：Jsp环境配置完全图解
  • 解释器-Java
  • 谈谈设计模式中的Iterator迭代器
  • 什么是j2ee
  • 菜鸟初学Java的备忘录（三）
  • 进化中Hibernate3脚本
  • Java基础学习:functor的实现
  • J2ME网络连接中显示问题的解决办法
  • JDBC驱动程序的类型
  • 开发完整J2EE解决方案的八个步骤 4
    		•
    【返回】 【顶部】 【关闭】
    Copyright © 2005-2010 www.594k.com All Rights Reserved.
    版权所有:JAVA学习网 备案序号:皖ICP备06004238号