java - 需要了解我的示例中的wait()和notify()行为吗？

public class class_Q {
volatile boolean valueSet = false;
volatile int n;



synchronized int get()
{
System.out.println("Now i am in get block and  valueset is : "+ valueSet  );
    if(!valueSet)
    {
        System.out.println("i am waiting in get block.....and releasing lock  ");
    try{
        wait();
    }catch(InterruptedException e)
        {
    System.out.println( "InterruptedException caught" );
        }
    }
    System.out.println( " value of n now in get block is  : " + n );
    valueSet=false;
    notify();
    return n;
}


   synchronized void put(int n)
     {
System.out.println(" Now i am in Put block and  valueset is : "+ valueSet);
if(valueSet)
{
try
{
System.out.println("i am waiting in put block......and releasing lock. ");
wait();
}catch(InterruptedException e)
{
System.out.println( "InterruptedException caught" );
}
}
  this.n = n;
  valueSet = true;
  System.out.println( "the value of n now in put block is : " + n );
  notify();
  }

}

 class Producer implements Runnable{
class_Q q;
Producer(class_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{
class_Q q;
 Consumer(class_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[])
{
    class_Q q = new class_Q();
    new Producer(q);
    new Consumer(q);
    System.out.println( "Press Control-C to stop." );
    }
}

*输出**




现在我在get块中，valueset为：false

我在获取块中等待.....并释放锁

按Control-C停止。

现在我在Put块中，valueset为：false

现在放在put块中的n的值是：0

现在get块中的n的值为：0

现在我在get块中，valueset为：false

我在获取块中等待.....并释放锁

现在我在Put块中，valueset为：false

现在放在put块中的n的值为：1

现在get块中的n的值为：1

在输出的第六行之后，我期望get（）线程唤醒（“ notify（）”）put（）线程。有人可以帮助我理解调用get（）线程背后的逻辑（换句话说，为什么它在get块中吗？）

最佳答案

我已经重新格式化了您的代码并更改了日志消息，因此所有内容都应该更加清晰。

public class Test {
  static class class_Q {
    volatile boolean valueSet = false;
    volatile int n;

    synchronized int get() throws InterruptedException {
      System.out.println("get entering - valueSet=" + valueSet);
      // *** Changed from `if` to `while`
      while (!valueSet) {
        System.out.println("get waiting");
        wait();
      }
      // Clear to set the value.
      valueSet = false;
      // Tell any put waits to finish
      notify();
      System.out.println("get finished - n=" + n);
      return n;
    }

    synchronized void put(int n) throws InterruptedException {
      System.out.println("put entering - valueSet=" + valueSet);
      // *** Changed from `if` to `while`
      while (valueSet) {
        System.out.println("put waiting");
        wait();
      }
      this.n = n;
      valueSet = true;
      System.out.println("put finished - n=" + n);
      notify();
    }
  }

  static class Producer implements Runnable {
    class_Q q;

    Producer(class_Q q) {
      this.q = q;
    }

    public void run() {
      int i = 0;
      try {
        while (true) {
          q.put(i++);
          System.out.println("put(" + (i-1) + ")");
        }
      } catch (InterruptedException ex) {
        // Just exit the run loop and finish when interrupted.
      }
    }
  }

  static class Consumer implements Runnable {
    class_Q q;

    Consumer(class_Q q) {
      this.q = q;
    }

    public void run() {
      try {
        while (true) {
          int i;
          i = q.get();
          System.out.println("get(" + i + ")");
        }
      } catch (InterruptedException ex) {
        // Just exit the run loop and finish when interrupted.
      }
    }
  }

  public static void main(String args[]) {
    class_Q q = new class_Q();
    Thread producer = new Thread(new Producer(q));
    Thread consumer = new Thread(new Consumer(q));
    System.out.println("Press Control-C to stop.");
    producer.start();
    consumer.start();
  }
}

我也做了三个主要更改。我已经将interrupted机制设置为退出线程。我使阻塞测试在阻塞状态下循环，而不仅仅是检查它们（while (x)而不是if (x)）。我已经使您的线程无法自动启动。

我认为，如果您现在运行此代码，则过程应该更加清晰，并且您应该能够更好地了解正在发生的事情。请记住，System.out是PrintWriter，因此可以被缓冲。

我得到的输出是：

输入-valueSet = false
放完-n = 0
放（0）
输入-valueSet = true
等待
按Control-C停止。
进入-valueSet = true
完成-n = 0
放完-n = 1
放（1）
输入-valueSet = true
等待
得到（0）
进入-valueSet = true
完成-n = 1
放完-n = 2
放（2）
输入-valueSet = true
等待
得到（1）
进入-valueSet = true
完成-n = 2
得到（2）
进入-valueSet = false
等待
放完-n = 3
完成-n = 3
得到（3）
进入-valueSet = false
等待
放（3）
输入-valueSet = false
放完-n = 4
完成-n = 4
得到（4）
进入-valueSet = false
等待
放（4）
...