使用java实现计数信号量

Question

我怀疑互斥体和信号量之间的显着区别在于，计数信号量支持超过一次的最大访问，因为互斥体一次最多只支持一次访问。

但是当执行如下时；

public class countingSemaphore{
 private static final int _MOSTTABLES = 3;  // whatever maximum number
 private static int availtable = _MOSTTABLES;

 public synchronized static void Wait(){  
  while(availtable==0){  
   try{
    wait();    
   }
   catch(InterruptedException e){
    e.printStackTrace();
   }
  }
  availtable--;  
 }

 public synchronized static void Signal(){
  while(availtable==_MOSTTABLES){
   try{
    wait();
   }
   catch(InterruptedException e){
    e.printStackTrace();
   }
  }
  availtable++;  
 }
}

问题是调用对象的非静态 wait() 方法。但是，我必须将同步应用于类而不是对象的实例，因为访问是在多个实例之间共享的。

如何解决 wait() 错误？我们在java中是否有其他方法或者我们必须自己实现wait()？

Answer 1

从概念上讲，您正在寻找一个信号量（用一个许可证初始化，其行为相当于互斥量）。

如果您无法使用 J2SE 5.0，那么我建议您查看它的前身 util.concurrent，它属于公共领域，可以在 J2SE 5.0 之前的 Java 版本上向后移植/使用（我也在有限的设备上使用了一些派生类）。

看一下 信号量 及其提供衍生类的顺序，例如 FIFO信号量。

如果您需要书架的指导和参考，我推荐“Java 中的并发编程”< /a>，作者：Doug Lea，他负责 util.concurrent 以及为我们带来 java.util.concurrent 的 JSR。

Answer 2

您在这里还有很多其他问题需要处理（如果您正在尝试实现并发控制对象），但是解决如何对静态级别构造使用等待/通知机制的特定问题的一种解决方案就是简单地理清这个概念构造中的监视器：您使用类的静态方法，但同步是在静态方法引用的对象（任何对象）的特定实例上执行的。例如：

public class MySemaphore {
   // ...
   private final Object lock = new Object();

   public static void acquire(int count) {
       while( ...) {
          synchronized(lock) {
              lock.wait();
          }
       }
   }
   public static void release(int count) {
       while( ...) {
          synchronized(lock) {
              lock.notifyAll();
          }
       }
   }
}