예를 통해 통지()와 통지All()의 본질적인 차이점에 대해 토론하십시오.-java지도 시간-php.cn

예를 통해 통지()와 통지All()의 본질적인 차이점에 대해 토론하십시오.

阿神

풀어 주다： 2017-03-18 10:09:00

원래의

2253명이 탐색했습니다.

notify() 및 notifyAll()은 개체를 기다리는 스레드에 알리기 위해 개체 개체에서 사용하는 메서드입니다. 둘 사이의 가장 큰 차이점은 다음과 같습니다.

notifyAll은 원래 객체에 대한 알림을 기다리고 있던 모든 스레드가 대기 상태를 종료하고 객체에 대한 잠금을 기다리게 한다는 것입니다. 경쟁할 것입니다.
알림은 알림을 보낼 대기 상태 스레드를 선택하고 개체에 대한 잠금을 획득하게 하지만 첫 번째 스레드가 완료될 때 알림을 기다리고 있는 다른 스레드에는 경고하지 않습니다. running 객체에 대한 잠금을 해제한 후 객체가 다시 알림 문을 사용하지 않으면 객체가 이미 유휴 상태이더라도 대기 상태에서 대기 중인 다른 스레드는 알림을 받지 못하기 때문에 계속 대기 상태에 있게 됩니다. 객체가 알림을 발행할 때까지 객체에 대한 알림 또는 informAll, 잠금이 아닌 알림 또는 informAll을 기다리고 있습니다.

다음은 좋은 예입니다.

import java.util.*;

class Widget...{}
class WidgetMaker extends Thread...{
    List<Widget> finishedWidgets=new ArrayList<Widget>();
    public void run()...{
        try...{
            while(true)...{
                Thread.sleep(5000);//act busy
                Widget w=new Widget();
                //也就是说需要5秒钟才能新产生一个Widget，这决定了一定要用notify而不是notifyAll
                //因为上面两行代码不是同步的，如果用notifyAll则所有线程都企图冲出wait状态
                //第一个线程得到了锁，并取走了Widget（这个过程的时间小于5秒，新的Widget还没有生成）
                //并且解开了锁，然后第二个线程获得锁(因为用了notifyAll其他线程不再等待notify语句
                //，而是等待finishedWidgets上的锁，一旦锁放开了，他们就会竞争运行)，运行
                //finishedWidgets.remove(0)，但是由于finishedWidgets现在还是空的，
                //于是产生异常
                //***********这就是为什么下面的那一句不能用notifyAll而是要用notify
                                
                synchronized(finishedWidgets)...{
                    finishedWidgets.add(w);
                    finishedWidgets.notify(); //这里只能是notify而不能是notifyAll
                }
            }
        }
        catch(InterruptedException e)...{}
    }
    
    public Widget waitForWidget()...{
        synchronized(finishedWidgets)...{
            if(finishedWidgets.size()==0)...{
                try...{
                    finishedWidgets.wait();
                }
                catch(InterruptedException e)
                ...{}
            }
            return finishedWidgets.remove(0);
        }
    }
}
public class WidgetUser extends Thread...{
    private WidgetMaker maker;
    public WidgetUser(String name,WidgetMaker maker)...{
        super(name);
        this.maker=maker;
    }
    public void run()...{
        Widget w=maker.waitForWidget();
        System.out.println(getName()+"got a widget");
    }
   

    public static void main(String[] args) ...{
        WidgetMaker maker=new WidgetMaker();
        maker.start();
        new WidgetUser("Lenny",maker).start();
        new WidgetUser("Moe",maker).start();
        new WidgetUser("Curly",maker).start();

    }

}

로그인 후 복사