Added the scala.concurrent.TaskRunner and scala...

Added the scala.concurrent.TaskRunner and
scala.concurrent.AsyncInvokable abstractions with corresponding
refactorings in scala.actors and scala.concurrent.

1 files changed, 24 insertions, 0 deletions

diff --git a/src/library/scala/concurrent/ManagedBlocker.scala b/src/library/scala/concurrent/ManagedBlocker.scala
new file mode 100644
index 0000000000..c77f97285e
--- /dev/null
+++ b/src/library/scala/concurrent/ManagedBlocker.scala
@@ -0,0 +1,24 @@
+package scala.concurrent
+
+/** The <code>ManagedBlocker</code> trait...
+ *
+ *  @author Philipp Haller
+ */
+trait ManagedBlocker {
+
+  /**
+   * Possibly blocks the current thread, for example waiting for
+   * a lock or condition.
+   * @return true if no additional blocking is necessary (i.e.,
+   * if isReleasable would return true).
+   * @throws InterruptedException if interrupted while waiting
+   * (the method is not required to do so, but is allowed to).
+   */
+  def block(): Boolean
+
+  /**
+   * Returns true if blocking is unnecessary.
+   */
+  def isReleasable: Boolean
+
+}