Java中的互斥方法执行

Question

我有两种方法：a() 和 b()。虽然我对多个线程同时访问任何方法感到满意（这是可取的），但我不希望任何线程在执行b() 时进入a()。 我该怎么做？

编辑 1

假设有 4 个线程，Thread 1 正在访问 A()。我想要的是所有 4 个线程都不应该使用B()。

Answer 1

检查底部的更新 - 我认为这种方法行不通。留作参考。

---

你可以使用Semaphore:

• 如果线程在b() 中，则尝试执行a() 的线程将阻塞，直到b() 的执行结束。
• 如果一个线程在b() 中并且第二个线程尝试运行b()，它将能够
• 如果有 2 个线程执行 a() 而 b() 没有被执行，两个线程都会运行

注意：一旦一个线程在a()并通过了“信号量测试”，另一个线程可以在a()结束之前开始运行b()

原理应该可以，但我没有测试过。

private final Semaphore inB = new Semaphore(1);

public void a() throws InterruptedException {
    inB.acquire(); //blocks until no thread is in b any longer
    //now we are good to go and execute a()
    //release the semaphore immediately for other threads who want to run a()
    inB.release(); 
    //rest of your code here
}
public void b() {
    //does not block to allow 2 thread running b() simultaneously
    boolean needToRelease = inB.tryAcquire(); 
    //rest of your code
    //if the permit was acquired, release it to allow threads to run a()
    if (needToRelease) {
        inB.release();
    }
}

编辑

您的意图不明确并且您的问题已被编辑，因为您的一个 cmets 说您希望 a() 和 b() 互斥（许多线程可以并行运行 a() 或 b()，但a() 和b() 永远不应该并行运行）。在这种情况下，您可以对 2 个信号量 inA 和 inB 使用相同的逻辑。

---

更新 => 错误

正如@yshavit 在对another answer 的评论中指出的那样，在以下场景中的代码中存在竞争条件：

• T1 运行a() 并获取inB
• T2 运行b() 并未能获取inB
• T1 发布inB
• T3 运行 a() 并设法获取 inB 尽管 T2 正在运行 b()

这似乎无法仅通过 Sempahores 实现。 This answer gives 更好的解决方案。

Answer 2

为简单起见省略了异常处理：

public class Test {
  private final Object lock = new Object();
  private int counterA;
  private int counterB;

  public void a() {
    synchronized(lock) {
      while(counterB > 0) {
        lock.wait();
      }
      ++counterA;
    }

    // do work

    synchronized(lock) {
      --counterA;
      lock.notifyAll();
    }
  }

  public void b() {
    synchronized(lock) {
      while(counterA > 0) {
        lock.wait();
      }
      ++counterB;
    }

    // do work

    synchronized(lock) {
      --counterB;
      lock.notifyAll();
    }
  }
}

Answer 3

java.util.concurrent.locks 是一个包含多个锁的 Java 包

在a()、take a lock 和release it 的末尾a()

在b()，对同一个锁做同样的事情

如果你想处理不对称行为，你可以使用ReadWriteLock，a() 是读取器，b() 是写入器：有几个 b() 锁，但有几个 a() 没有。