如何从线程 1 等待，直到线程 2 发出通知

Question

我是多线程的新手，当我阅读有关多线程的内容时，我想编写这个精美的多线程代码来执行以下操作。

我的柜台类如下。

class Counter {
  private int c = 0;

  public void increment() {
    System.out.println("increment value: "+c);
      c++;
  }

  public void decrement() {
      c--;
      System.out.println("decrement value: "+c);
  }

  public int value() {
      return c;
  }

}

这个计数器对象由两个线程共享。一旦线程启动，我需要做以下事情。我希望Thread2一直等到Thread1将Counter对象的计数加1。完成后，线程1通知线程2，然后线程1开始等待线程2将值递减1。然后，线程2启动并将值递减1，并再次通知线程1，然后线程2开始等待线程1。重复这个过程几次。

我怎样才能做到这一点。提前非常感谢。

我已经做到了以下几点。

public class ConcurrencyExample {

  private static Counter counter;
  private static DecrementCount t1;
  private static IncrementCount t2;

  public static void main(String[] args) {
    Counter counter = new Counter();
    Thread t1 = new Thread(new IncrementCount(counter));
    t1.start();

    Thread t2 = new Thread(new DecrementCount(counter));
    t2.start();

  }

}


public class DecrementCount implements Runnable {

  private static Counter counter;

  public DecrementCount(Counter counter) {
    this.counter = counter;
  }

  @Override
  public void run() {
    for (int i = 0; i < 1000; i++) {
      counter.decrement();     
      System.out.println("decreamented");
    }
  }

}


public class IncrementCount implements Runnable {

  private static Counter counter;

  public IncrementCount(Counter counter) {
    this.counter = counter;
  }

  @Override
  public void run() {
    for (int i = 0; i < 1000; i++) {
      counter.increment();
      System.out.println("Incremented");
    }

  }

}

Answer 1

- 首先，您的增量（）和递减（）必须使用同步关键字以避免争用条件 请参阅此布莱恩规则

当我们编写刚刚被另一个线程读取的变量，或者读取最近由另一个线程写入的变量时，必须使用同步。访问字段数据的原子语句/方法也必须同步。

-它的JVM Thread Scheduler可以控制哪个线程将进入运行状态，它将在那里停留多长时间，以及工作完成后它将去哪里。

- 人们无法确定哪个线程将首先运行.....

-您还可以使用java.util中的SingleThreadExecutor。concurrent，完成一个任务后再进行第二个任务。

Answer 2

同步器使线程能够彼此等待。请参阅CountDownLatch和信号量。

请参见java.util.concurrent包中的同步器一节

Answer 3

查看信号量。您将需要两个，每个线程一个：内信号量和 dec 信号量。在递减计数中执行：

for (int i = 0; i < 1000; i++) {
  decSemaphore.acquire();
  counter.decrement();     
  System.out.println("decreamented");
  incSemaphore.release();
}

对称地实现< code>IncrementCount。对于< code>decSemaphore，incSemaphore的初始值应为< code>1和< code>0。

顺便说一句，您的计数器也需要同步（请参阅同步关键字和原子交互器）。