Merge pull request #32 from Chymyst/feature/no-unit-arg

Get rid of assumed unit argument in molecules

Author: winitzki

README.md

@@ -188,7 +188,7 @@ There is an integer counter value, to which we have non-blocking access via `inc
 We can also fetch the current counter value via the `get` molecule, which is blocking.
 The counter is initialized to the number we specify.
 ```scala
-import code.winitzki.jc.JoinRun._
+import code.winitzki.jc._
 import code.winitzki.jc.Macros._
 
 // Define the logic of the “non-blocking counter”.
@@ -238,7 +238,7 @@ The library offers some debugging facilities:
  Here are the typical results:
 
 ```scala
-import code.winitzki.jc.JoinRun._
+import code.winitzki.jc._
 import code.winitzki.jc.Macros._
 
 val counter = b[Int] // the name of this molecule is "counter"

benchmark/src/main/scala/code/winitzki/benchmark/Benchmarks1.scala

@@ -3,9 +3,8 @@ package code.winitzki.benchmark
 import java.time.LocalDateTime
 
 import code.winitzki.benchmark.Common._
-import code.winitzki.jc.Pool
+import code.winitzki.jc._
 import code.winitzki.jc.Macros._
-import code.winitzki.jc.JoinRun._
 
 object Benchmarks1 {
 
@@ -96,7 +95,7 @@ object Benchmarks1 {
     }
     j2.c(count)
 
-    (1 to count).foreach{ _ => j2.d() }
+    (1 to count).foreach{ _ => j2.d(()) }
     j2.f(initialTime)
   }
 
@@ -105,7 +104,7 @@ object Benchmarks1 {
     val initialTime = LocalDateTime.now
 
     val (d,_,f,_) = make_counter2a(count)
-    (1 to count).foreach{ _ => d() }
+    (1 to count).foreach{ _ => d(()) }
     f(initialTime)
   }
 

benchmark/src/main/scala/code/winitzki/benchmark/Benchmarks4.scala

@@ -3,9 +3,8 @@ package code.winitzki.benchmark
 import java.time.LocalDateTime
 
 import code.winitzki.benchmark.Common._
-import code.winitzki.jc.JoinRun._
+import code.winitzki.jc._
 import code.winitzki.jc.Macros._
-import code.winitzki.jc.Pool
 
 object Benchmarks4 {
   val differentReactions = 100
@@ -57,7 +56,7 @@ object Benchmarks4 {
         case a2(n) => a3(n)
         case a3(n) => a4(n)
         case a4(n) => a5(n)
-        case a5(m) => if (m==0) f() else a0(m-1)
+        case a5(m) => if (m==0) f(()) else a0(m-1)
       }
       a0(count)
 
@@ -281,7 +280,7 @@ object Benchmarks4 {
 //        case a97(n) => a98(n)
 //        case a98(n) => a99(n)
 
-        case a99(m) => if (m==0) f() else a0(m-1)
+        case a99(m) => if (m==0) f(()) else a0(m-1)
       }
       a0(count)
 

benchmark/src/main/scala/code/winitzki/benchmark/Benchmarks7.scala

@@ -3,7 +3,6 @@ package code.winitzki.benchmark
 import java.time.LocalDateTime
 import code.winitzki.benchmark.Common._
 import code.winitzki.jc._
-import code.winitzki.jc.JoinRun._
 import code.winitzki.jc.Macros._
 
 object Benchmarks7 {
@@ -54,11 +53,11 @@ object Benchmarks7 {
     val initialTime = LocalDateTime.now
     j8.all_done(count)
     val d = make_counters8a(j8.done, numberOfCounters, count)
-    (1 to (count*numberOfCounters)).foreach{ _ => d() }
+    (1 to (count*numberOfCounters)).foreach{ _ => d(()) }
     j8.f(initialTime)
   }
 
-  def make_counters(done: M[Unit], counters: Int, init: Int, tp: Pool) = {
+  private def make_counters(done: E, counters: Int, init: Int, tp: Pool) = {
     val c = m[Int]
     val d = m[Unit]
 
@@ -71,13 +70,13 @@ object Benchmarks7 {
     d
   }
 
-  def make_counters8a(done: AsyName[Unit], counters: Int, init: Int): AsyName[Unit] = {
+  private def make_counters8a(done: AsyName[Unit], counters: Int, init: Int): AsyName[Unit] = {
     object j8a extends Join {
       object c extends AsyName[Int]
       object d extends AsyName[Unit]
 
       join {
-        case c(0) => done()
+        case c(0) => done(())
         case c(n) and d(_) if n > 0 => c(n-1)
       }
 

benchmark/src/main/scala/code/winitzki/benchmark/Benchmarks9.scala

@@ -3,20 +3,19 @@ package code.winitzki.benchmark
 import java.time.LocalDateTime
 import code.winitzki.benchmark.Common._
 import code.winitzki.jc._
-import code.winitzki.jc.JoinRun._
 import code.winitzki.jc.Macros._
 import scala.concurrent.duration._
 
 object Benchmarks9 {
 
   val numberOfCounters = 5
 
-  def make_counter_1(done: M[Unit], counters: Int, init: Int, tp: Pool): B[Unit,Unit] = {
+  def make_counter_1(done: M[Unit], counters: Int, init: Int, tp: Pool): EE = {
     val c = m[Int]
     val d = b[Unit, Unit]
 
     site(tp)(
-      go { case c(0) => done() },
+      go { case c(0) => done(()) },
       go { case c(n) + d(_, r) if n > 0 => c(n - 1); r() }
     )
     (1 to counters).foreach(_ => c(init))
@@ -47,7 +46,7 @@ object Benchmarks9 {
   }
 
 
-  def make_ping_pong_stack(done: M[Unit], tp: Pool): B[Int,Int] = {
+  def make_ping_pong_stack(done: E, tp: Pool): B[Int,Int] = {
     val c = m[Unit]
     val d = b[Int, Int]
     val e = b[Int, Int]
@@ -141,8 +140,8 @@ object Benchmarks9 {
       object d extends SynName[Unit, Unit]
 
       join {
-        case c(0) => done()
-        case c(n) and d(_) if n > 0 => c(n-1); d.reply()
+        case c(0) => done(())
+        case c(n) and d(_) if n > 0 => c(n-1); d.reply(())
       }
     }
     import b9c1._
@@ -171,7 +170,7 @@ object Benchmarks9 {
     all_done(numberOfCounters)
 
     val d = make_counter_1_Jiansen(done, numberOfCounters, count)
-    (1 to (count*numberOfCounters)).foreach{ _ => d() }
+    (1 to (count*numberOfCounters)).foreach{ _ => d(()) }
 
     var result = f(initialTime)
     result

benchmark/src/main/scala/code/winitzki/benchmark/JiansenJoin.scala

@@ -132,7 +132,7 @@ class AsyName[Arg](implicit owner: Join, argT:ClassTag[Arg]) extends NameBase{
   *  @param argT   the descriptor the argument type
   *  @param resT   the descriptor the return type
   */
-class SynName[Arg, R](implicit owner: Join, argT:ClassManifest[Arg], resT:ClassManifest[R]) extends NameBase{
+class SynName[Arg, R](implicit owner: Join, argT:ClassTag[Arg], resT:ClassTag[R]) extends NameBase{
   // does not support subtyping
 
   override def argTypeEqual(t:Any) :Boolean = t match {

benchmark/src/main/scala/code/winitzki/benchmark/MainApp.scala

@@ -1,11 +1,10 @@
 package code.winitzki.benchmark
 
-import code.winitzki.benchmark.Benchmarks1._
-import code.winitzki.benchmark.Benchmarks4._
-import code.winitzki.benchmark.Benchmarks7._
-import code.winitzki.benchmark.Benchmarks9._
-import code.winitzki.jc.{FixedPool, Pool}
-import code.winitzki.jc.JoinRun.{defaultSitePool, defaultReactionPool}
+import Benchmarks1._
+import Benchmarks4._
+import Benchmarks7._
+import Benchmarks9._
+import code.winitzki.jc._
 
 object MainAppConfig {
 

benchmark/src/test/scala/code/winitzki/benchmark/JiansenFairnessSpec.scala

@@ -31,17 +31,20 @@ class JiansenFairnessSpec extends FlatSpec with Matchers with TimeLimitedTests {
 
       join {
         case getC(_) and done(arr) => getC.reply(arr)
-        case a0(_) and c((n, arr)) => if (n > 0) { arr(0) += 1; c((n-1,arr)); a0() } else done(arr)
-        case a1(_) and c((n, arr)) => if (n > 0) { arr(1) += 1; c((n-1,arr)); a1() } else done(arr)
-        case a2(_) and c((n, arr)) => if (n > 0) { arr(2) += 1; c((n-1,arr)); a2() } else done(arr)
-        case a3(_) and c((n, arr)) => if (n > 0) { arr(3) += 1; c((n-1,arr)); a3() } else done(arr)
+        case a0(_) and c((n, arr)) => if (n > 0) { arr(0) += 1; c((n-1,arr)); a0(()) } else done(arr)
+        case a1(_) and c((n, arr)) => if (n > 0) { arr(1) += 1; c((n-1,arr)); a1(()) } else done(arr)
+        case a2(_) and c((n, arr)) => if (n > 0) { arr(2) += 1; c((n-1,arr)); a2(()) } else done(arr)
+        case a3(_) and c((n, arr)) => if (n > 0) { arr(3) += 1; c((n-1,arr)); a3(()) } else done(arr)
       }
 
     }
-    j3.a0(); j3.a1(); j3.a2(); j3.a3()
+    j3.a0(())
+    j3.a1(())
+    j3.a2(())
+    j3.a3(())
     j3.c((N, Array.fill[Int](reactions)(0)))
 
-    val result = j3.getC()
+    val result = j3.getC(())
 
 //    println(result.mkString(", "))
 
@@ -81,7 +84,7 @@ class JiansenFairnessSpec extends FlatSpec with Matchers with TimeLimitedTests {
     Thread.sleep(200)
     j4.c(cycles)
 
-    val result = j4.getC()
+    val result = j4.getC(())
 
 //    println(result.mkString(", "))
 

benchmark/src/test/scala/code/winitzki/benchmark/MergesortSpec.scala

@@ -1,7 +1,6 @@
 package code.winitzki.benchmark
 
-import code.winitzki.jc.FixedPool
-import code.winitzki.jc.JoinRun._
+import code.winitzki.jc._
 import code.winitzki.jc.Macros._
 import org.scalatest.{FlatSpec, Matchers}
 

benchmark/src/test/scala/code/winitzki/benchmark/MultithreadSpec.scala

@@ -1,7 +1,6 @@
 package code.winitzki.benchmark
 
-import code.winitzki.jc.FixedPool
-import code.winitzki.jc.JoinRun._
+import code.winitzki.jc._
 import code.winitzki.jc.Macros._
 import org.scalatest.{FlatSpec, Matchers}
 import Common._