Java 一个临界区多个信号量

Question

我需要知道，是否有一些框架可以为我提供这种功能。我在一个方法中有一个关键部分，我需要很少的其他方法等到这个关键部分被执行和完成。如果临界区不活跃，这些方法应该可以流畅地工作。

如果只有在信号量方法中没有线程时才进入临界区。

如：

public class Worker {

    private Critical critical = null;
    private CriticalDependent dep1 = null; 
    private CriticalDependent dep2 = null;

    public Worker() {

        critical = new Critical();
        dep1 = critical.registerDependent();
        dep2 = critical.registerDependent();

    }
    public void critical() {
         critical.enter();
         critical.waitForClearToGo();

         // protected unique code
         // change resource handle etc

         critical.exit();
    }

    public void dependent1() {
         critical.checkWaitAndUnsetClearToGo(this.dep1);

         // some dependent code
         // use resource handle

         critical.setClearToGo(this.dep1);
    }

    public void dependent2() {
         critical.checkWaitAndUnsetClearToGo(this.dep2);

         // some dependent code
         // use resource handle

         critical.setClearToGo(this.dep2);
    }
}

我可以想出一些解决方案，但我更喜欢使用现有的框架。而且我找不到现有的。提前谢谢你。

Answer 1

使用标准的 Java Semaphore。

Answer 2

正如 Erik 所说，您可以使用 Java 的 Semaphore 来做到这一点。 但是你需要一个有 2 个许可的，这样你的 2 个依赖方法可以同时运行，但是临界区会阻塞两个依赖方法。

Semaphore semaphore = new Semaphore(2, true);  // Make it fair, so critical section won't wait unnecessarily

public void critical() {
    semaphore.acquire(2); // Blocks both dependents, waiting if they're not available
    ...
    semaphore.release(2);
}

public void dep1() {
    semaphore.acquire(); // Blocks only if critical() has both permits
    ...
    semaphore.release();
}

public void dep2() {
    semaphore.acquire(); // Ditto, dep1() can have the other permit
    ...
    semaphore.release();
}