added Stepan's patch ops/SyncVar

1 files changed, 26 insertions, 7 deletions

diff --git a/src/library/scala/concurrent/SyncVar.scala b/src/library/scala/concurrent/SyncVar.scala
index 9b852e4cb5..6b9ca33395 100644
--- a/src/library/scala/concurrent/SyncVar.scala
+++ b/src/library/scala/concurrent/SyncVar.scala
@@ -1,7 +1,7 @@
 /*                     __                                               *\
 **     ________ ___   / /  ___     Scala API                            **
-**    / __/ __// _ | / /  / _ |    (c) 2003-2006, LAMP/EPFL             **
-**  __\ \/ /__/ __ |/ /__/ __ |                                         **
+**    / __/ __// _ | / /  / _ |    (c) 2003-2007, LAMP/EPFL             **
+**  __\ \/ /__/ __ |/ /__/ __ |    http://scala-lang.org/               **
 ** /____/\___/_/ |_/____/_/ | |                                         **
 **                          |/                                          **
 \*                                                                      */
@@ -14,24 +14,43 @@ package scala.concurrent
 
 /** The class <code>SyncVar</code> ...
  *
- *  @author  Martin Odersky
+ *  @author  Martin Odersky, Stepan Koltsov
  *  @version 1.0, 10/03/2003
  */
-class SyncVar[a] {
+class SyncVar[A] {
   private var isDefined: Boolean = false
-  private var value: a = _
+  private var value: A = _
+  private var exception: Option[Throwable] = None
 
   def get = synchronized {
     while (!isDefined) wait()
-    value
+    if (exception.isEmpty) value
+    else throw exception.get
   }
 
-  def set(x: a) = synchronized {
+  def set(x: A) = synchronized {
     value = x
     isDefined = true
+    exception = None
     notifyAll()
   }
 
+  private def setException(e: Throwable) = synchronized {
+    exception = Some(e)
+    isDefined = true
+    notifyAll()
+  }
+
+  def setWithCatch(x: => A) = synchronized {
+    try {
+      this set x
+    } catch {
+      case e =>
+        this setException e
+        throw e
+    }
+  }
+
   def isSet: Boolean = synchronized {
     isDefined
   }