java - Wait() 和 Notify() 概念 - Java 多线程

Question

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

  synchronized int get () {
    if ( !valueSet ) {
      try {
        wait();
      } catch ( InterruptedException e ) {
        System.out.println( "InterruptedException 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( "InterruptedException 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." );
  }
}

我无法理解这是如何工作的。以这个流程为例。 Producer进入put方法，调用notify()。如果 wait() 还没有被消费者调用怎么办？还有，一旦生产者调用了notify()，生产者还没有松开监听器，消费者如何进入get()方法呢？请帮帮我。

Answer 1

我假设顶部的类是 Q，它缺少一些代码。无论如何，一般的想法是 boolean 值 valueSet和 wait()/notify()通话协同工作。

如果消费者已经开始等待，他已经通过synchronized get()获得了Q实例的锁。方法，然后在他等待时释放它。

如果消费者还没有开始等待，生产者可能会锁定 Q 实例，因为 put()方法在同一个锁上同步。一旦生产者退出锁，他将调用 notify() 并将 valueSet boolean 值设置为 true。

消费者下一次调用get()将读取 boolean 值在尝试等待之前，注意那里有东西，获取n的内容并做任何需要的工作。如果没有设置该值，这意味着在消费者不在的情况下没有任何东西进来，他会 wait()锁定新工作和下一个notify()会叫醒他。

更新

在评论中的场景中，您实际上是在询问完全相同的情况，但恰恰相反。同样的逻辑也适用。

消费者正在等待，生产者调用notify() .生产者当前拥有锁，并将在该方法的持续时间内继续持有锁。全部notify()所做的是让当前等待锁的另一个线程知道，当锁被释放时，它可以尝试获取锁并恢复执行。在这种情况下，只有一个其他线程，但如果有多个线程，那么它只会选择一个(为了唤醒所有人，应该调用 notifyAll())。

1. 生产者退出方法，释放锁。
2. 消费者醒来并拿走了锁。

此时，生产者是否已经过来并正在等待锁，或者是否尚未进入方法，这是不明确的。 boolean 标志和 wait() 的相同串联/notify()这也适用。

在消费者通过退出方法释放锁之前，它会将 boolean 标志设置为 false 并调用 notify() .

如果生产者当前已经在等待锁，调用notify()将让它知道它可以在锁被释放时唤醒并继续。

如果生产者没有等待 wait()调用，它必须在方法之外(可能等待进入方法并以这种方式获取锁)。当消费者退出方法并释放锁时，生产者获取它并检查 boolean 标志。它已设置为 false，因此生产者不会尝试调用 wait()并且只是降低它的值(value)，设置 boolean 标志并调用notify() .