Logo Search packages:      
Sourcecode: scala version File versions  Download package

void scala::actors::FJTaskRunnerGroup::execute ( Runnable  r  )  throws InterruptedException [inline]

Arrange for execution of the given task by placing it in a work queue. If the argument is not of type FJTask, it is embedded in a FJTask via FJTask.Wrap.

Exceptions:
InterruptedException if current Thread is currently interrupted

Definition at line 277 of file FJTaskRunnerGroup.java.

References entryQueue, scala::actors::LinkedQueue::put(), and signalNewTask().

                                                              {
    if (r instanceof FJTask) {
      entryQueue.put((FJTask)r);
    }
    else {
      entryQueue.put(new FJTask.Wrap(r));
    }
    signalNewTask();
  }


Generated by  Doxygen 1.6.0   Back to index