2

我有一个函数，一旦布尔变量为真，就需要调用它。我尝试在线程中使用 while 循环，但它不起作用。这是我尝试过的：

public class MyRunnable implements Runnable {

public void run() {
    while (true) {
         if (conditions == true) { 
             System.out.println("second");
             break;
         }
    }
}

public static void main(String args[]) {
    boolean condition = false;
    (new Thread(new MyRunnable())).start();
    System.out.println("first\n");
    // set conndition to true
    condition = true;

    }

}

结果应该是：

first
second
4

3 回答 3

14

不要忙于等待这种情况。使用阻塞习语。对于您的简单情况，您可以使用new CountDownLatch(1). 首先，这是您的代码，但已按您期望的方式编译和运行：

public class MyRunnable implements Runnable {
  volatile boolean condition = false;

  public void run() {
    while (true) {
      if (condition) {
        System.out.println("second");
        break;
      }
    }
  }
  public static void main(String args[]) {
    final MyRunnable r = new MyRunnable();
    new Thread(r).start();
    System.out.println("first\n");
    r.condition = true;
  }
}

为了比较，一个带有 的程序CountDownLatch：

public class MyRunnable implements Runnable {
  final CountDownLatch latch = new CountDownLatch(1);

  public void run() {
    try { latch.await(); } catch (InterruptedException e) {}
    System.out.println("second");
  }

  public static void main(String args[]) {
    final MyRunnable r = new MyRunnable();
    new Thread(r).start();
    System.out.println("first\n");
    r.latch.countDown();
  }
}

要真正注意到差异，请在后面添加一个Thread.sleep(20000)，println("first")然后听听计算机风扇努力消耗第一个程序浪费的能量的声音的差异。

于 2012-10-14T17:08:17.650 回答
3

这似乎是 java 的等待通知构造的地方。

public class MyRunnable implements Runnable {

  public run() {
    synchronized(this) {
      try {
        wait();
      } catch (InterruptedException e) {
      }
    }
    System.out.println("second");
  }

  public static void main(String args[]) {
    Runnable r = new MyRunnable();    
    Thread t = new Thread(r);
    t.start();
    System.out.println("first\n");
    synchronized (r) {
      r.notify();
    }
  }

}
于 2012-10-14T17:14:09.720 回答
0

不要那样做。相反，您可以使用Object' 的内置方法notify()，wait()如下所示：

public class MyRunnable implements Runnable {

private final Object condition;

public MyRunnable(Object condition) {
    this.condition = condition;
}

public void run() {
    condition.wait();
    System.out.println("second");
}

public void go(String args[]) {
        Object condition = new Object();
        (new Thread(new MyRunnable(condition))).start();
        System.out.println("first\n");
        // set conndition to true
        condition.notify();
    }
}

如果您想要更高级的通知方案，您还可以寻找java.util.concurrent更强大的方法让线程等待更有趣的条件。所有这些都将比仅旋转直到条件为真时的 CPU 效率要高得多，并且由于 Java 内存模型中的细微差别，它们不太可能引入并发错误。

于 2012-10-14T17:12:26.493 回答