Scala：屏障同步是如何实现的？

Question

任何人都知道如何在 scala?我猜它正在使用信号量，但我想知道它到底是如何工作的，有人知道吗？

我想一种天真的想法可能是为每个进程创建一组信号量。有更好/更有效的实施吗？

Answer 1

我会使用 java.util.concurrent.CountDownLatch 或 java.util.concurrent.CyclicBarrier。

Answer 2

好吧，对不起这些人，我终于找到了。以防万一有人感兴趣。

class Barrier(n:Int){
  assert(n>1);
  private var waiting = 0; // number of processes currently waiting
  private val waitSem = new Semaphore; waitSem.down
  private val mutex = new Semaphore;

  def sync = {
    mutex.down;
    if(waiting==n-1){ waitSem.up; }
    else{ 
      waiting+=1; mutex.up; waitSem.down; 
      // Wait until woken
      waiting-=1; 
      if(waiting==0) mutex.up; else waitSem.up;
    }
  }
}