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。