|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.ObjectaQute.libg.forker.Forker<T>
T
- public class Forker<T>
A Forker is good in parallel scheduling tasks with dependencies. You can add
tasks with doWhen(Collection, Object, Runnable)
. The collection is
the list of dependencies, the object is the target, and the runnable is run
to update the target. The runnable will only run when all its dependencies
have ran their associated runnable.
Constructor Summary | |
---|---|
Forker()
Constructor |
|
Forker(Executor executor)
Constructor |
Method Summary | |
---|---|
void |
cancel(long ms)
Cancel the forker. |
void |
doWhen(Collection<? extends T> dependencies,
T target,
Runnable runnable)
Schedule a job for execution when the dependencies are done of target are done. |
int |
getCount()
|
void |
start(long ms)
|
void |
sync(long ms)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public Forker(Executor executor)
executor
- public Forker()
Method Detail |
---|
public void doWhen(Collection<? extends T> dependencies, T target, Runnable runnable)
dependencies
- the dependencies that must have runtarget
- the target, is removed from all the dependencies when it ranrunnable
- the runnable to runpublic void start(long ms) throws InterruptedException
InterruptedException
public void sync(long ms) throws InterruptedException
InterruptedException
public void cancel(long ms) throws InterruptedException
InterruptedException
public int getCount()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |