diff options
Diffstat (limited to 'docs/examples/pilib/twoPlaceBuffer.scala')
-rw-r--r-- | docs/examples/pilib/twoPlaceBuffer.scala | 67 |
1 files changed, 67 insertions, 0 deletions
diff --git a/docs/examples/pilib/twoPlaceBuffer.scala b/docs/examples/pilib/twoPlaceBuffer.scala new file mode 100644 index 0000000000..686547b344 --- /dev/null +++ b/docs/examples/pilib/twoPlaceBuffer.scala @@ -0,0 +1,67 @@ +package examples.pilib; + +import scala.concurrent.pilib._; + +/** Two-place buffer specification and implementation. */ +object twoPlaceBuffer with Application { + + /** + * Specification. + */ + def Spec[a](in: Chan[a], out: Chan[a]): unit = { + + def B0: unit = choice ( + in * (x => B1(x)) + ); + + def B1(x: a): unit = choice ( + out(x) * (B0), + in * (y => B2(x, y)) + ); + + def B2(x: a, y: a): unit = choice ( + out(x) * (B1(y)) + ); + + B0 + } + + /** + * Implementation using two one-place buffers. + */ + def Impl[a](in: Chan[a], out: Chan[a]): unit = { + ///- ... complete here ... + // one-place buffer + def OnePlaceBuffer[a](in: Chan[a], out: Chan[a]): unit = { + def B0: unit = choice ( in * (x => B1(x)) ); + def B1(x: a): unit = choice ( out(x) * (B0)); + B0 + } + val hidden = new Chan[a]; + spawn < OnePlaceBuffer(in, hidden) | OnePlaceBuffer(hidden, out) > + ///+ + } + + val random = new java.util.Random(); + + def Producer(n: Int, in: Chan[String]): unit = { + Thread.sleep(random.nextInt(1000)); + val msg = "" + n; + choice (in(msg) * {}); + Producer(n + 1, in) + } + + def Consumer(out: Chan[String]): unit = { + Thread.sleep(random.nextInt(1000)); + choice (out * { msg => () }); + Consumer(out) + } + + val in = new Chan[String]; + in.attach(s => System.out.println("put " + s)); + val out = new Chan[String]; + out.attach(s => System.out.println("get " + s)); + //spawn < Producer(0, in) | Consumer(out) | Spec(in, out) > + spawn < Producer(0, in) | Consumer(out) | Impl(in, out) > + +} |