diff options
author | Philipp Haller <hallerp@gmail.com> | 2009-06-23 15:49:40 +0000 |
---|---|---|
committer | Philipp Haller <hallerp@gmail.com> | 2009-06-23 15:49:40 +0000 |
commit | d09ec90432258a34e4afcd803c4e1fc10338d695 (patch) | |
tree | 0b1cd417dc553e83517d986572d587e7bcc4f087 /src/actors/scala/actors/IScheduler.scala | |
parent | 3f9bbdbc7827070c09ab87331623740fa226221b (diff) | |
download | scala-d09ec90432258a34e4afcd803c4e1fc10338d695.tar.gz scala-d09ec90432258a34e4afcd803c4e1fc10338d695.tar.bz2 scala-d09ec90432258a34e4afcd803c4e1fc10338d695.zip |
Thread-based receive uses ManagerBlocker interf...
Thread-based receive uses ManagerBlocker interface of new ForkJoinPool.
Diffstat (limited to 'src/actors/scala/actors/IScheduler.scala')
-rw-r--r-- | src/actors/scala/actors/IScheduler.scala | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/src/actors/scala/actors/IScheduler.scala b/src/actors/scala/actors/IScheduler.scala index 49b42d39d6..811fd47ce3 100644 --- a/src/actors/scala/actors/IScheduler.scala +++ b/src/actors/scala/actors/IScheduler.scala @@ -10,6 +10,8 @@ package scala.actors +import forkjoin.ForkJoinPool + /** * The <code>IScheduler</code> trait provides a common interface * for all schedulers used to execute actor tasks. @@ -63,4 +65,8 @@ trait IScheduler { * @param f the closure to be registered */ def onTerminate(a: Reactor)(f: => Unit): Unit + + def managedBlock(blocker: ForkJoinPool.ManagedBlocker) { + blocker.block() + } } |