如何使用 AtomicBoolean 阻塞和等待

Question

我正在寻找一种暂停线程的方法。

我从有效地使用布尔标志（称为“暂停”）开始，并使用 while 循环（暂停）包装检查。

在 while 循环中有一个 Thread.wait() 来阻止执行。

我一直在研究 AtomicBoolean，除了不会阻塞之外，它似乎可以解决问题。

是否存在具有块方法的 AtomicBoolean 的替代或扩展版本？

即AtomicBoolean.getFalse() 之类的 AtomoicBoolean.get(false)？

他们有一个阻塞队列，所以有一个阻塞值。

当前设置是：

while (paused.get()) {
        synchronized (paused) {
            try {

                paused.wait();
            } catch (Exception e) {
            }

            paused.notify();
        }
    }

与

public void pause() {
    if (paused.compareAndSet(false, true)) {
        synchronized (paused) {
            paused.notify();
        }
    }

}


public void resume() {
    if (paused.compareAndSet(true, false)) {
        synchronized (paused) {
            paused.notify();
        }
    } 
}

Answer 1

您可以使用锁。

在你的帖子中。

while(!Thread.interrupted()) {
  lock.lock();
  try {
      // do something.
  } finally {
      lock.unlock();
  }
}

// to pause
lock.lock();

// to unpause
lock.unlock(); // has to be the same thread which locked.

---

或者您可能会忙于睡眠，具体取决于您需要多快唤醒线程。

while(atomicBoolean.get()) Thread.sleep(100); // or yield();

Answer 2

要么你在等待一个特定的时间，这可以用Thread.sleep()来完成，要么你需要等待for某事，这表明你需要在对象上调用wait()你正在等待准备好。

如果您确实需要手动告诉您的线程继续工作，请构建一个包含Thread.sleep() 调用的while(true) 循环并检查一个布尔值，如果设置正确，该布尔值会导致break。不过，我真的想不出这样做的理由。

Answer 3

我不确定我是否理解您的问题；无论如何，您是否看过 java.util.concurrent.Semaphore 类？ 带有 permit=1 的信号量应该给你想要的行为，你可以模仿你的

暂停=真；

使用说明

semaphore.tryAcquire();

或

信号量.acquire();

如果你想锁定来电者。 您可以使用

释放线程

semaphore.release();

Answer 4

    AtomicBoolean lock = new AtomicBoolean(false);
    if(lock.compareAndSet(false, true)){
        try {
            //do something
        } catch(Exception e){
            //error handling
        } finally {
            lock.set(false);
        }
    }

首先，除非您使用原子操作（例如测试和设置），否则AtomicBoolean 与常规布尔值一样无用（如果它们是可变的）。这里我使用compareAndSet，因此只有在标志关闭时它才会进入临界区。请记住始终在 finally 中解锁。

要使用标志暂停线程，不要进行主动等待（线程主体中的一些循环询问“我暂停了吗？”），因为这不是一种有效的做法。我会使用等待通知方案。当线程没有更多工作要做时，它会在某个对象上调用wait。然后，为了重新启动，其他一些线程在同一个对象上调用 notify。

如果您想立即暂停（在设置标志时跳过执行），您可以将代码分成尽可能多的步骤，并用测试包装每个步骤，如果暂停则最终等待：

public void run(){
    while(true){
        if(!paused){
            //do something
        }

        if(!paused){
            //do something
        }

        if(!paused){
            //do something
        }

        if(!paused){
            //do something
        }

        if(paused){
            //wait on some object
        }
    }       
}   

根据您的代码，这些步骤甚至可能是嵌套的，或者包括涉及多个步骤的不可分割的执行单元。

Answer 5

使用 1 的 CountDownLatch：

CountDownLatch conditionLatch = new CountDownLatch(1);

在你想等待某个条件成立的地方：

conditionLatch.await();

在你要设置条件为真的地方：

conditionLatch.countDown();