Threads Multithreading, Producer/Consumer, notify()

[Iago]

Hallo Miteinander,

Gerne möchte ich die Funktionalität von notify() bezüglich des Consumer-Threads (s.u.) besser verstehen.

Wenn ich das Programm starte gibt der Producer Thread eine "Frage" (int-Wert) aus. Im Producer-Thread
wird notify() aufgerufen, der Consumer-Thread übernimmt und beantwortet die Frage zugleich und löscht die Frage von der Liste
mit remove(). (s.u.)

Wenn ich mir nun den Programm-Code anschaue, folgt auf die Beantwortung der Frage "ANSWERED Questions:" sofort die Zeile: "No questions to Answer ... waiting for Producer to get questions"

Jetzt meine Frage: Ist es so, dass hier durch notif() hier DERSELBE Thread wieder gestartet wird? Oder liegt es an der while-Schleife (bei run()),
dass sofort while(questionList.size() == LIMIT); aufgerufen wird.

Vielen Dank!

public class Consumer implements Runnable {

    List<Integer> questionList = null;
    
    public Consumer(List<Integer> questionsList) {
        super();
        this.questionList = questionsList;
    }   
    
    public void answerQuestion() throws InterruptedException {
        synchronized(questionList){
            while(questionList.isEmpty()) {
                System.out.println("No questions to Answer ... waiting for Producer to get questions");
                questionList.wait();
        }   
        }
        
        synchronized(questionList) {
            Thread.sleep(5000);           
            System.out.println("ANSWERED Questions: " + questionList.remove(0));
            questionList.notify();
        }
    }   
    
    @Override
    public void run() {       
        while(true) {           
            try {
                answerQuestion();
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }   
    }
}

 

[Iago]

Korrektur: Wenn ich mir nun die Ausgabe anschaue:

New Question: 0
ANSWERED Questions: 0
No questions to Answer ... waiting for Producer to get questions  <------
New Question: 1
New Question: 2
New Question: 3
ANSWERED Question: 1
ANSWERED Question: 2
New Question: 4
.....

 

[mihe7]

Wie sieht denn Dein Producer-Thread genau aus?

 

[Iago]

public class Producer implements Runnable {

   List<Integer> questionList = null;
   final int LIMIT = 5;
   private int questionNo;

    public Producer(List<Integer> questionList) {
         this.questionList = questionList; 
    } 

    public void readQuestion(int questionNo) throws InterruptedException {

       synchronized(questionsList) {
               while(questionList.size() == LIMIT) {
                     System.out.println("Questions have piled up .. wait for answers");
                    questionList.wait();
    }
    }

       synchronized(questionList) {

                System.out.println("New Question: " + questionNo);
                questionList.add(questionNo);
                Thread.sleep(100);
                questionList.notify();
                }
                }

              
      public void run() {
           while(true){
             try {
              readQuestion(questionNo++);
         }   
         catch (InterruptedException e) {}
      }         

}

 

[Iago]

Ist es so, dass hier durch notif() hier DERSELBE Thread wieder gestartet wird

Falsch.. der Kollege aus Pakistan schreibt: "notify() wakes up the fist thread that called wait() on the same object"

Aber dann beleibt trotzdem die Frage, was ist wenn der erste thread wait() gar nicht aufruft??

 

[mihe7]

Aber dann beleibt trotzdem die Frage, was ist wenn der erste thread wait() gar nicht aufruft??

Nichts, was soll dann sein?

 

[Iago]

Nichts, was soll dann sein?

Ja, klar!!