Проблемы с потребителями-производителями с использованием java-потоков

Question

Я написал код для проблемы с производителем-потребителем, где производитель производит товар три раза, а затем потребитель потребляет товар один раз. Приведенный ниже код работает нормально как требование, но основной поток не остановится. Я не знаю, почему это не остановится, я не могу поймать. Не могли бы вы, пожалуйста, взглянуть в нижнем коде и исправить?

public class ProducerConsumerProblem 
{ 

    public static void main(String[] args) 
    { 

    ProducerConsumerStack st = new ProducerConsumerStack(); 
    new ProducerThread(st); 
    new ConsumerThread(st); 

    } 
} 

class ProducerConsumerStack 
{ 
    int x; 
    boolean flag = false; 
    int producedCount = 0; 

    public synchronized void push(int x) 
    { 
    if (flag) 
    { // flag==true 
     try 
     { 
     wait(); 
     } 
     catch (Exception e) 
     { 
     System.out.println(e); 
     } 
    } 
    this.x = x; 
    System.out.println(x + " is produced.."); 
    try 
    { 
     Thread.sleep(250); 
    } 
    catch (Exception e) 
    { 
     System.out.println(e); 
    } 

    this.producedCount++; 
    if (this.producedCount == 3) 
    { 
     this.producedCount = 0; 
     this.flag = true; 
     notifyAll(); 
    } 

    } 

    synchronized public void pop() 
    { 
    if (!flag) 
    { // flag==false 
     try 
     { 
     wait(); 
     } 
     catch (Exception e) 
     { 
     System.out.println(e); 
     } 
    } 
    System.out.println(x + " is consumed.\n"); 
    try 
    { 
     Thread.sleep(1500); 
    } 
    catch (Exception e) 
    { 
     System.out.println(e); 
    } 
    flag = false; 
    notify(); 
    } 
} 

class ProducerThread implements Runnable 
{ 
    ProducerConsumerStack st = null; 

    ProducerThread(ProducerConsumerStack st) 
    { 
    this.st = st; 
    Thread t1 = new Thread(this); 
    t1.start(); 
    } 

    public void run() 
    { 
    int a = 1; 
    for (int i = 0; i < 15; i++) 
    { 
     st.push(a++); 
    } 
    } 
} 

class ConsumerThread implements Runnable 
{ 
    ProducerConsumerStack st = null; 

    ConsumerThread(ProducerConsumerStack st) 
    { 
    this.st = st; 
    Thread t2 = new Thread(this); 
    t2.start(); 
    } 

    public void run() 
    { 
    for (int i = 0; i < 15; i++) 
    { 
     st.pop(); 
    } 
    } 
} 

Answer 1

@james большой: Пожалуйста, запустите тот же код, а затем посмотреть, является ли основной поток отделки или нет. Это совсем не конец.

Я побежал программу с одним небольшим изменением: Я добавил поток, который ждет в основной поток, чтобы умереть, а затем выводит сообщение: «! Спокойной ночи»

public class ProducerConsumerProblem 
{ 
    static volatile Thread mainThread; 
    public static void main(String[] args) 
    { 
     mainThread = Thread.currentThread(); 
     ProducerConsumerStack st = new ProducerConsumerStack(); 
     new ProducerThread(st); 
     new ConsumerThread(st); 

     new Thread(() -> { 
      try { 
       mainThread.join(); 
      } catch (Exception ex) { 
       System.out.println("Aaaaaaaugh!"); 
      } 
      System.out.println("Nighty Night!"); 
     }).start(); 

    } 
} 

напечатанное, доказав, что основная нить сделала на самом деле умереть.

нить, которая не прекращает была потребительской нити: К тому времени, когда производитель нить обозвал st.push() пятнадцать раз, потребитель тред только завершил пять вызовов st.pop(), и он застрял в шесте вызова, ожидая уведомление, которое никогда не произойдет.

---

Возможно, вы захотите ознакомиться со своим классом ProducerConsumerStack. Вы помещаете «стек» в свое имя, но для меня это не похоже на стек. Во-первых, стек должен иметь возможность хранить более одного элемента. Ваш может хранить только один.