@Ignore @Test public void testTaskDependencyExecutionOrder() throws Exception { this.tg = new TaskGraph(); this.tg.addTask(this.A); this.tg.addTask(this.B); this.tg.addTask(this.C, this.A); this.tg.addTask(this.D, this.A); this.job = this.je.submit("Job-parallel-nested", this.tg, true); this.job.waitForCompletion(); assertTrue(this.C.taskOrder > this.A.taskOrder); assertTrue(this.D.taskOrder > this.A.taskOrder); this.tg = new TaskGraph(); this.tg.addTask(this.A); this.tg.addTask(this.B); this.tg.addTask(this.C, this.A); this.tg.addTask(this.D, this.B); this.job = this.je.submit("Job-parallel-branches", this.tg, true); this.job.waitForCompletion(); assertTrue(this.C.taskOrder > this.A.taskOrder); assertTrue(this.D.taskOrder > this.B.taskOrder); this.tg = new TaskGraph(); this.tg.addTask(this.A); this.tg.addTask(this.B, this.A); this.tg.addTask(this.C, this.B); this.tg.addTask(this.D, this.C); this.job = this.je.submit("Job-sequential-tasks", this.tg, true); this.job.waitForCompletion(); assertTrue(this.B.taskOrder > this.A.taskOrder); assertTrue(this.C.taskOrder > this.B.taskOrder); assertTrue(this.D.taskOrder > this.C.taskOrder); this.tg = new TaskGraph(); this.tg.addTask(this.A); this.tg.addTask(this.B); this.tg.addTask(this.C); this.tg.addTask(this.D); this.job = this.je.submit("Job-parallel-tasks", this.tg, true); this.job.waitForCompletion(); verifyJobPersistence(this.job); }
public Job submit(String name, TaskGraph taskGraph, JobCompletionListener listener, boolean persistent) throws Exception { return initJob(name, taskGraph, null, listener, null, persistent); }
JobEngine { public Job submit(String name, TaskGraph taskGraph, JobCompletionListener listener, boolean persistent) throws Exception { return initJob(name, taskGraph, null, listener, null, persistent); } }
JobEngine { public Job submit(String name, TaskGraph taskGraph, JobCompletionListener listener, boolean persistent) throws Exception { return initJob(name, taskGraph, null, listener, null, persistent); } private  JobEngine(); }
JobEngine { public Job submit(String name, TaskGraph taskGraph, JobCompletionListener listener, boolean persistent) throws Exception { return initJob(name, taskGraph, null, listener, null, persistent); } private  JobEngine(); synchronized void init(int jobThreadPoolSize, int taskThreadPoolSize); static synchronized JobEngine getEngine(); void shutdown(); void logStatus(); Job submit(String name, TaskGraph taskGraph, JobCompletionListener listener, boolean persistent); Job submit(String name, TaskGraph taskGraph, JobCompletionListener jobListener,
            TaskChangeListener taskListener, boolean persistent); Job submit(String name, TaskGraph taskGraph, boolean persistent); Job submit(String name, TaskGraph taskGraph, Set<LockObjectReference> objects, JobCompletionListener listener); Job submit(String name, TaskGraph taskGraph, Set<LockObjectReference> objects,
            JobCompletionListener jobListener, TaskChangeListener taskListener); Job submit(String name, TaskGraph taskGraph, Set<LockObjectReference> objects); Job submit(String name, TaskGraph taskGraph, Set<LockObjectReference> objects,
            JobCompletionListener jobCompletionListener, TaskChangeListener taskChangeListener, boolean persistent); boolean isActive(); static void setJobThreadPoolSize(String value); static void setTaskThreadPoolSize(String value); synchronized void abortJob(Long jobId, String reason); void addJobCompletionListener(JobCompletionListener listener); void removeJobCompletionListener(JobCompletionListener listener); synchronized Job getJobByTask(Task task); }
JobEngine { public Job submit(String name, TaskGraph taskGraph, JobCompletionListener listener, boolean persistent) throws Exception { return initJob(name, taskGraph, null, listener, null, persistent); } private  JobEngine(); synchronized void init(int jobThreadPoolSize, int taskThreadPoolSize); static synchronized JobEngine getEngine(); void shutdown(); void logStatus(); Job submit(String name, TaskGraph taskGraph, JobCompletionListener listener, boolean persistent); Job submit(String name, TaskGraph taskGraph, JobCompletionListener jobListener,
            TaskChangeListener taskListener, boolean persistent); Job submit(String name, TaskGraph taskGraph, boolean persistent); Job submit(String name, TaskGraph taskGraph, Set<LockObjectReference> objects, JobCompletionListener listener); Job submit(String name, TaskGraph taskGraph, Set<LockObjectReference> objects,
            JobCompletionListener jobListener, TaskChangeListener taskListener); Job submit(String name, TaskGraph taskGraph, Set<LockObjectReference> objects); Job submit(String name, TaskGraph taskGraph, Set<LockObjectReference> objects,
            JobCompletionListener jobCompletionListener, TaskChangeListener taskChangeListener, boolean persistent); boolean isActive(); static void setJobThreadPoolSize(String value); static void setTaskThreadPoolSize(String value); synchronized void abortJob(Long jobId, String reason); void addJobCompletionListener(JobCompletionListener listener); void removeJobCompletionListener(JobCompletionListener listener); synchronized Job getJobByTask(Task task); static final int DEFAULT_JOB_THREAD_POOL_SIZE; static final int DEFAULT_TASK_THREAD_POOL_SIZE; }