Непонятно, в чем ошибка программы?

Question

[Андрей Романов]

Здравствуйте! Я изучаю Java по последнему изданию книги Шилдта, и у меня возникла ошибка с одним из примеров. В консоль данный код выводит только "Для остановки нажмите Ctrl-C", а сама работа потоков не выводится. В чем может быть проблема?

public class Q {
    int n;
    boolean valueSet = false;


    synchronized int get(){
        while(!valueSet)
            try{
                wait();
            } catch(InterruptedException e){
                System.out.println("Исключение типа InterruptedException перехвачено");
            }
        System.out.println("Получено: " + n);
        valueSet = false;
        notify();
        return n;
    }

    synchronized void out(int n){
        while(valueSet)
            try{
                wait();
            } catch(InterruptedException e){
                System.out.println("Исключение типа InterruptedException перехвачено");
            }
        this.n = n;
        valueSet = true;
        System.out.println("отправлено: " + n);
        notify();
       }

    public void put(int i) {
        i++;
    }
}
  class Producer implements Runnable{
      Q q;

      Producer(Q q){
          this.q = q;
          new Thread(this, "Поставщик").start();
      }

      @Override
      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, "Потребитель").start();
      }

      @Override
      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("Для остановки нажмите Ctrl-C");
    }
}

Answer 1

[gausdrem]

ты учишь по 8 изданию
тогда там такой код
// правильная реализация поставшика ипотребителя.
class Q {
int n;
boolean valueSet = false;
synchronized int get () {
while ( ! valueSet )
try {
wait ();
} catch ( InterruptedException e ) {
System.out.println ( " InterruptedException perehvacheno ");
}
System.out.println ( " Polycheno " + n );
valueSet = false;
notify ();
return n;
}
synchronized void put ( int n) {
while ( valueSet)
try {
wait ();
} catch ( InterruptedException e ) {
System.out.println ( " InterruptedException perehvacheno ");
}
this.n = n;
valueSet = true;
System.out.println ( " Otpravleno: " + n);
notify();
}
}
class Producer implements Runnable {
Q q;
Producer ( Q q) {
this.q = q;
new Thread ( this, " Postavshik " ).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, " Potrebitel " ).start ();
}
public void run () {
while ( true ) {
q.get ();
}
}
}
class PC {
public static void main ( String args []) {
Q q = new Q ();
new Producer (q);
new Consumer ( q );
System.out.println ( " Dli ostanvci nagmite Control-C. ");
}
}
кроме сообщений это мои надписи

Comments

[Андрей Романов]

Спасибо большое, я просто отметил классы как вложенные, а надо было по отдельности. Все заработало!

Answer 2

[pavel null]

Попробуй у дочерних потоков вызвать join()

Comments

[Андрей Романов]

Вышла такая ошибка:
Exception in thread "main" java.lang.NullPointerException
at Producer.(Q.java:42)
at PCFixed.main(Q.java:75)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:483)
at com.intellij.rt.execution.application.AppMain.main(AppMain.java:134)

[Андрей Романов]

Что делать?

[pavel null]

без куска кода мне сложно увидеть ошибку

[pavel null]

по идее должно было быть так
Thread t = new Thread(this, "Поставщик")
t.start();
t.join()

[Андрей Романов]

one pavel: Вот измененные дочерние потоки, но сейчас просто вызывается пустая консоль, и ничего более:
class Producer implements Runnable{
Q q;

Producer(Q q) throws InterruptedException {
this.q = q;
Thread t1 = new Thread(this, "Поставщик");
t1.start();
t1.join();
}

@Override
public void run() {
int i = 0;

while(true){
q.put(i++);
}

}
}
class Consumer implements Runnable{
Q q;

Consumer(Q q) throws InterruptedException {
this.q = q;
Thread t2 = new Thread(this, "Потребитель");
t2.start();
t2.join();
}

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

[pavel null]

Нашел, у тебя q.put(i++); a должно быть q.out(i++);

[pavel null]

но про join почитай в документации, поймешь почему предложил его =)

[Андрей Романов]

one pavel: Все равно не помогло. Выводит только "Отправлено : 0", и все.

[pavel null]

Ну а join'ы нужно удалить

[Андрей Романов]

one pavel: Хорошо, спасибо вам большое!