Scala：Barrier同步是如何实现的？

Question

任何人有任何想法Barrier Synchronization如何在scala内部实施？我猜测它使用的是Semaphores，但我想知道它的工作原理，有人知道吗？

我想一个天真的想法可能是为每个进程创建一个Semaphores数组。任何更好/更有效的实现？

Answer 1

好的，对不起这个家伙，我终于找到了。这里是任何人有兴趣的情况。

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; 
    } 
    } 
} 

Answer 2

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