From d063a9fa5162bf6f59b34d653b46534830310a50 Mon Sep 17 00:00:00 2001
From: Philipp Haller <hallerp@gmail.com>
Date: Tue, 21 Jul 2009 17:35:01 +0000
Subject: Enabled synchronous message sends for Replyable...

Enabled synchronous message sends for ReplyableReactor. Added
get(timeout: Long) method to SyncVar.
---
 src/library/scala/concurrent/SyncVar.scala | 14 ++++++++++++++
 1 file changed, 14 insertions(+)

(limited to 'src/library')

diff --git a/src/library/scala/concurrent/SyncVar.scala b/src/library/scala/concurrent/SyncVar.scala
index 3b35c9ef10..d64c2fa51c 100644
--- a/src/library/scala/concurrent/SyncVar.scala
+++ b/src/library/scala/concurrent/SyncVar.scala
@@ -28,6 +28,20 @@ class SyncVar[A] {
     else throw exception.get
   }
 
+  def get(timeout: Long): Option[A] = synchronized {
+    if (!isDefined) {
+      try {
+        wait(timeout)
+      } catch {
+        case _: InterruptedException =>
+      }
+    }
+    if (exception.isEmpty) {
+      if (isDefined) Some(value) else None
+    } else
+      throw exception.get
+  }
+
   def take() = synchronized {
     try {
       get
-- 
cgit v1.2.3