Example17.8

17.8 同期チャネル

同期チャネルの実装例を見てみましょう。ここではメッセージの送信者はメッセージが受け取られるまでブロックします。同期チャネルは、転送するメッセージを保持するのにただ１つの変数を必要としますが、リーダーとライタープロセスをうまく連動させるために３つの信号を使います。

 package scala.concurrent

 class SyncChannel[A] {
   private var data: A = _
   private var reading = false
   private var writing = false

     def write(x: A) = synchronized {
       while (writing) wait()
       data = x
       writing = true
         if (reading) notifyAll()
         else while (!reading) wait()
     }

     def read: A = synchronized {
       while (reading) wait()
       reading = true
       while (!writing) wait()
       val x = data
       writing = false
       reading = false
       notifyAll()
       x
     }
 }

前ページ　17 章　目次　次ページ

---