From 740c36ace1b1efd328bc887a935b4e1ce2a6f1ef Mon Sep 17 00:00:00 2001
From: stepancheg <stepancheg@epfl.ch>
Date: Tue, 10 Jun 2008 19:52:33 +0000
Subject: SyncVar enhancements:

* deprecation of "exception" field
* addition of blocking-queue-like "take", "put" methods
* change of "unset" signature
---
 test/files/run/sync-var.scala | 53 +++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 53 insertions(+)
 create mode 100644 test/files/run/sync-var.scala

(limited to 'test/files/run/sync-var.scala')

diff --git a/test/files/run/sync-var.scala b/test/files/run/sync-var.scala
new file mode 100644
index 0000000000..aa6ae9fa34
--- /dev/null
+++ b/test/files/run/sync-var.scala
@@ -0,0 +1,53 @@
+import java.util.concurrent._
+import java.util.concurrent.atomic._
+
+object Test { def main(args: Array[String]) {
+
+val n = 10000
+val i = new AtomicInteger(n)
+val j = new AtomicInteger(n)
+val sum = new AtomicInteger
+
+val q = new scala.concurrent.SyncVar[Int]
+
+val producers = (1 to 3).force map { z => new Thread {
+  override def run() {
+    var again = true
+    while (again) {
+      val x = i.getAndDecrement()
+      if (x > 0)
+        q put x
+      else
+        again = false
+    }
+  }
+} }
+
+val summers = (1 to 7).force map { z => new Thread {
+  override def run() {
+    val x = j.decrementAndGet()
+    if (x >= 0) {
+      sum addAndGet q.take()
+    }
+    if (x > 0) {
+      run()
+    } else {
+      // done
+    }
+  }
+} }
+
+summers foreach { _.start() }
+producers foreach { _.start() }
+
+summers foreach { _.join() }
+
+val got = sum.get
+val expected = (n + 1) * n / 2
+println(got + " " + expected + " " + (got == expected))
+
+producers foreach { _.join() }
+
+} }
+
+// vim: set ts=2 sw=2 et:
-- 
cgit v1.2.3