java 为什么notify和notifyAll都不起作用?

class Example{
    public static void main(String arr[]){
        ThreadB th1=new ThreadB("th1");
        ThreadB th2=new ThreadB("th2");
        }
}
class ThreadB implements Runnable{
    C c;
    Thread thread;
    ThreadB(String name){
        c=new C();
        thread=new Thread(this,name);
        thread.start();
        }
    public void run(){
        if(thread.getName().equals("th1")){
            for(int i=0;i<3;i++)c.t1(false);
            c.t1(true);
            }
        if(thread.getName().equals("th2")){
            for(int i=0;i<3;i++)c.t2(false);
            c.t2(true);
            }
        System.out.println("end");
        }
}
class C{
    synchronized void t1(boolean boo){
            if(boo){
                notify();
                return;
                }
            System.out.println("t1");
            notify();
            try{
                wait();
                }catch(InterruptedException exc){System.out.println(exc);}
        }
    synchronized void t2(boolean boo){
            if(boo){
                System.out.println();notify();return;
                }
            System.out.println("t2");
            notify();//notifyAll()也没效果;
        }
}

调用了notify()无法唤醒th1线程。

阅读 4.7k
2 个回答

每个线程初始化的时候都是 c=new C(),锁住的是不同的对象。

class Example{
    public static void main(String arr[]){
        C c = new C();
        ThreadB th1=new ThreadB("th1",c);
        ThreadB th2=new ThreadB("th2",c);
    }
}
class ThreadB implements Runnable{
    C c;
    Thread thread;
    ThreadB(String name,C c){
        //c=new C();
        this.c=c;
        thread=new Thread(this,name);
        thread.start();
    }
    public void run(){
        if(thread.getName().equals("th1")){
            for(int i=0;i<3;i++)c.t1(false);
            c.t1(true);
        }
        if(thread.getName().equals("th2")){
            for(int i=0;i<3;i++)c.t2(false);
            c.t2(true);
        }
        System.out.println("end");
    }
}
class C{
    synchronized void t1(boolean boo){
        if(boo){
            notify();
            return;
        }
        System.out.println("t1");
        notify();
        try{
            wait();
        }catch(InterruptedException exc){System.out.println(exc);}
    }
    synchronized void t2(boolean boo){
        if(boo){
            System.out.println();notify();return;
        }
        System.out.println("t2");
        notify();//notifyAll()也没效果;
    }
}

这两个线程wait的对象C不是同一个,是感知不到对方的锁的

撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进
推荐问题