Продюсер/потребитель, использующий многопоточность в Java

Question

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

объект данных:

class Q 
{ 
    int n; 
    boolean valueset=false; 

    synchronized int get() 
    { 
     if(!valueset) 

      try 
      { 
       wait(); 
      } 
      catch(InterruptedException e) 
      { 
       System.out.println("Interrupted Exception Caught."); 
      } 


      System.out.println("Got:"+n); 
      valueset=false; 
      notify(); 
      return n; 

    } 

    synchronized void put(int n) 
    { 
     if(valueset) 

      try 
      { 
       wait(); 
      } 
      catch(InterruptedException e) 
      { 
       System.out.println("Interrupted Exception Caught."); 
      } 

      this.n=n; 
      valueset=true; 
      System.out.println("Put:"+n); 
      notify(); 

    } 
} 

Производитель:

class Producer implements Runnable 
{ 
    Q q; 
    Producer(Q q) 
    { 
     this.q=q; 
     new Thread(this,"Producer").start(); 
    } 

     public void run() 
     { 
      int i=0; 
      while(true) 
      { 
       q.put(i++); 
      } 
     } 

} 

Потребитель:

class Consumer implements Runnable 
{ 
    Q q; 
    Consumer(Q q) 
    { 
     this.q=q; 
     new Thread(this,"Consumer").start(); 
    } 

     public void run() 
     { 
      while(true) 
      { 
       q.get(); 
      } 
     } 

} 

Экстра класс:

class PCfixed 
{ 
    public static void main(String[] args) 
    { 
     Q q=new Q(); 
     new Producer(q); 
     new Consumer(q); 

     System.out.println("Press Control-C to stop."); 
    } 
} 

Answer 1

Возможно, невозможно будет ответить правильно без дополнительной информации, но следующая проблема определенно (хотя может и не быть тем, с чем вы сталкиваетесь):
Вы не звоните wait() в цикле! javedocs ясно указывает

... приложения должны защищать против него путем тестирования при условии, что должно было привести нить к пробуждению, и продолжает ждать , если условие не выполнено. Другими словами, всегда ждет должно происходить в петлях ...

Более подробную информацию можно найти в этом thread

Answer 2

В обоих Producer и Consumer, вы пытаетесь определить метод public void run()внутри в конструктор. Кудрявые фигурные скобки находятся не в том месте.