Example17.7

「Example17.7」の編集履歴（バックアップ）一覧はこちら

「Example17.7」(2011/02/24 (木) 09:14:43) の最新版変更点

追加された行は緑色になります。

削除された行は赤色になります。

#co(){
17.7 Asynchronous Channels

A fundamental way of interprocess communication is the asynchronous channel. Its implementation makes use the following simple class for linked lists:
}

** 17.7 非同期チャネル

プロセス内通信の基本的な方法には非同期チャネルがあります。その実装では次の単純な連結リストを利用しています。

  class LinkedList[A] {
    var elem: A = _
    var next: LinkedList[A] = null
  }

#co(){
To facilitate insertion and deletion of elements into linked lists, every reference into a linked list points to the node which precedes the node which conceptually forms the top of the list. Empty linked lists start with a dummy node, whose successor is null.
}

連結リストへの要素の挿入・追加を助けるために、連結リストの中への参照はすべて、リストの先頭を概念的に表すノードの手前のノードを指します。空きの連結リストはダミーノードで始まり、次の要素は nullです。

#co(){
The channel class uses a linked list to store data that has been sent but not read yet. At the opposite end, threads that wish to read from an empty channel, register their presence by incrementing the nreaders field and waiting to be notified.
}

チャネルクラスは、送られたがまだ読み出されていないデータを保持するのに連結リストを使います。反対の端では、空きのチャネルから読み出そうとするスレッドは nreaders フィールドをインクリメントすることで自分を登録し、通知されるのを待ちます。

  package scala.concurrent
 
  class Channel[A] {
    class LinkedList[A] {
      var elem: A = _
      var next: LinkedList[A] = null
    }
    private var written = new LinkedList[A]
    private var lastWritten = written
    private var nreaders = 0
 
      def write(x: A) = synchronized {
        lastWritten.elem = x
        lastWritten.next = new LinkedList[A]
        lastWritten = lastWritten.next
        if (nreaders > 0) notify()
      }
 
      def read: A = synchronized {
        if (written.next == null) {
          nreaders = nreaders + 1; wait(); nreaders = nreaders - 1
        }
        val x = written.elem
        written = written.next
        x
      }
  }

#center(){[[前ページ>Example17.6]]　[[ 17 章>Chapter 17 Abstractions for Concurrency]]　[[目次>ScalaByExample和訳]]　[[次ページ>Example17.8]]}

----
#comment

#co(){
17.7 Asynchronous Channels

A fundamental way of interprocess communication is the asynchronous channel. Its implementation makes use the following simple class for linked lists:
}


#setmenu2(ex-r-menu)
** 17.7 非同期チャネル

プロセス内通信の基本的な方法には非同期チャネルがあります。その実装では次の単純な連結リストを利用しています。

  class LinkedList[A] {
    var elem: A = _
    var next: LinkedList[A] = null
  }

#co(){
To facilitate insertion and deletion of elements into linked lists, every reference into a linked list points to the node which precedes the node which conceptually forms the top of the list. Empty linked lists start with a dummy node, whose successor is null.
}

連結リストへの要素の挿入・追加を助けるために、連結リストの中への参照はすべて、リストの先頭を概念的に表すノードの手前のノードを指します。空きの連結リストはダミーノードで始まり、次の要素は nullです。

#co(){
The channel class uses a linked list to store data that has been sent but not read yet. At the opposite end, threads that wish to read from an empty channel, register their presence by incrementing the nreaders field and waiting to be notified.
}

チャネルクラスは、送られたがまだ読み出されていないデータを保持するのに連結リストを使います。反対の端では、空きのチャネルから読み出そうとするスレッドは nreaders フィールドをインクリメントすることで自分を登録し、通知されるのを待ちます。

  package scala.concurrent
 
  class Channel[A] {
    class LinkedList[A] {
      var elem: A = _
      var next: LinkedList[A] = null
    }
    private var written = new LinkedList[A]
    private var lastWritten = written
    private var nreaders = 0
 
      def write(x: A) = synchronized {
        lastWritten.elem = x
        lastWritten.next = new LinkedList[A]
        lastWritten = lastWritten.next
        if (nreaders > 0) notify()
      }
 
      def read: A = synchronized {
        if (written.next == null) {
          nreaders = nreaders + 1; wait(); nreaders = nreaders - 1
        }
        val x = written.elem
        written = written.next
        x
      }
  }

#center(){[[前ページ>Example17.6]]　[[ 17 章>Chapter 17 Abstractions for Concurrency]]　[[目次>ScalaByExample和訳]]　[[次ページ>Example17.8]]}

----
#comment