Notifyall – Java – Fórum – Programujte.com

Mam problem s nasledujicim kodem:

public class CekaciTrida extends Thread {
    @Override
    synchronized public void run() {
        System.out.println("ceka");
        try {
            wait();
        } catch (InterruptedException ex) {
            Logger.getLogger(CekaciTrida.class.getName()).log(Level.SEVERE, null, ex);
        }
        System.out.println("probuzek - konci");
       
    }//edn of method
}

//---------------------------------------------------------------------------------------------------------

public class ProbouzeciTrida extends Thread {
    @Override
    synchronized public void run() {
        try {
            Thread.sleep(2000);
        } catch (InterruptedException ex) {
            Logger.getLogger(ProbouzeciTrida.class.getName()).log(Level.SEVERE, null, ex);
        }
        notify();
        System.out.println("probudil jsem ho");

    }
}

//------------------------------------------------------------------------------------------------------------------------------------



synchronized public static void main(String[] args) {
        // TODO code application logic here
       
        CekaciTrida cekaci = new CekaciTrida();
        ProbouzeciTrida probouzeci = new ProbouzeciTrida();
       
       
      
       
        cekaci.start();
        System.out.println("kurde");
        probouzeci.start();
       
    }

Proc se mi prvni vlakno neprobudi z wait, ikdyz volam notifyall? Diky.

Protože wait(), notify() a notifyAll() operují jen s objektem, pro který byly zavolány. Tj. wait() na jednom objektu nereaguje na notify()/notifyAll() na jiném objektu.

Ty tam v podstatě máš cekaci.wait() a probouzeci.notify(), proto to nefunguje.

Můžeš to upravit třeba takhle:

class CekaciTrida extends Thread {
    @Override
    synchronized public void run() {
        System.out.println("ceka");
        try {
            wait();
        } catch (InterruptedException ex) {
            Logger.getLogger(CekaciTrida.class.getName()).log(Level.SEVERE, null, ex);
        }
        System.out.println("probuzen - konci");
    }
}

class ProbouzeciTrida extends Thread {
    private CekaciTrida ct;

    public ProbouzeciTrida(CekaciTrida ct) {
        this.ct = ct;
    }

    @Override
    synchronized public void run() {
        try {
            Thread.sleep(2000);
        } catch (InterruptedException ex) {
            Logger.getLogger(ProbouzeciTrida.class.getName()).log(Level.SEVERE, null, ex);
        }

        synchronized (ct) {
            ct.notify();
        }
        System.out.println("probudil jsem ho");
    }
}
...

CekaciTrida cekaci = new CekaciTrida();
ProbouzeciTrida probouzeci = new ProbouzeciTrida(cekaci);

Takže to ve výsledku udělá cekaci.wait() a cekaci.notify().

Případně s "externím" objektem pro signalizaci (což může být lepší řešení, ale to asi ještě nemusíš řešit):

Object sig = new Object();
CekaciTrida cekaci = new CekaciTrida(sig); // ... sig.wait();
ProbouzeciTrida probouzeci = new ProbouzeciTrida(sig); // ... sig.notify();