diff options
author | Martin Odersky <odersky@gmail.com> | 2003-03-10 11:55:36 +0000 |
---|---|---|
committer | Martin Odersky <odersky@gmail.com> | 2003-03-10 11:55:36 +0000 |
commit | d5da7d9aa5a8d4833775454853e81ead20cc37a7 (patch) | |
tree | d48297de81cb6c84853b94ae02b6edabee5bce5f /sources/examples | |
parent | 1fb5a195b5575e7015be4fd1ee8f89116a78cfb5 (diff) | |
download | scala-d5da7d9aa5a8d4833775454853e81ead20cc37a7.tar.gz scala-d5da7d9aa5a8d4833775454853e81ead20cc37a7.tar.bz2 scala-d5da7d9aa5a8d4833775454853e81ead20cc37a7.zip |
*** empty log message ***
Diffstat (limited to 'sources/examples')
-rw-r--r-- | sources/examples/ComputeServer.scala | 32 | ||||
-rw-r--r-- | sources/examples/boundedbuffer.scala | 30 | ||||
-rw-r--r-- | sources/examples/futures.scala | 12 |
3 files changed, 74 insertions, 0 deletions
diff --git a/sources/examples/ComputeServer.scala b/sources/examples/ComputeServer.scala new file mode 100644 index 0000000000..e322860b78 --- /dev/null +++ b/sources/examples/ComputeServer.scala @@ -0,0 +1,32 @@ +package examples; + +import concurrent._, concurrent.ops._; + +class ComputeServer(n: Int) { + private trait Job { + type t; + def task: t; + def return(x: t): Unit; + } + + private val openJobs = new Channel[Job](); + + private def processor(i: Int): Unit { + while (True) { + val job = openJobs.read; + job.return(job.task) + } + } + def future[a](def p: a): () => a { + val reply = new SyncVar[a](); + openJobs.write{ + new Job with { + type t = a; + def task = p; + def return(x: a) = reply.set(x); + } + } + () => reply.get + } + replicate(1,n){processor} +} diff --git a/sources/examples/boundedbuffer.scala b/sources/examples/boundedbuffer.scala new file mode 100644 index 0000000000..f308d0d472 --- /dev/null +++ b/sources/examples/boundedbuffer.scala @@ -0,0 +1,30 @@ +package examples; + +import concurrent.ops._; + +class BoundedBuffer[a](N: Int) extends Monitor() with { + var in = 0, out = 0, n = 0; + val elems = new Array[a](N); + + def put(x: a) = synchronized { + await (n < N); + elems(in) = x ; in = (in + 1) % N ; n = n + 1; + if (n == 1) notifyAll(); + } + + def get: a = synchronized { + await (n != 0); + val x = elems(out) ; out = (out + 1) % N ; n = n - 1; + if (n == N - 1) notifyAll(); + x + } +} + +module test { + val buf = new BoundedBuffer[String](10); + var cnt = 0; + def produceString = { cnt = cnt + 1; cnt.toString() } + def consumeString(ss: String) = System.out.println(ss); + spawn { while (True) { val ssss = produceString ; buf.put(ssss) } } + spawn { while (True) { val s = buf.get ; consumeString(s) } } +}
\ No newline at end of file diff --git a/sources/examples/futures.scala b/sources/examples/futures.scala new file mode 100644 index 0000000000..1e218351af --- /dev/null +++ b/sources/examples/futures.scala @@ -0,0 +1,12 @@ +package examples; +import concurrent.ops._; +module futures { + def someLengthyComputation = 1; + def anotherLengthyComputation = 2; + def f(x: Int) = x + x; + def g(x: Int) = x * x; + val x = future(someLengthyComputation); + anotherLengthyComputation; + val y = f(x()) + g(x()); + System.out.println(y); +}
\ No newline at end of file |