Changes between Version 5 and Version 6 of ComputeStartExample1

Timestamp:

2010-11-05T13:05:13+01:00 (15 years ago)

Author:

george

Comment:

--

ComputeStartExample1

@@ -17 +17 @@
 }}}
 
-A job consists of a number of steps which consists of a number of operation. The entire data model explanation is available [http://www.molgenis.org/wiki/ComputeDataModel here]. Operation are submitted to the Worker on the cluster in the loop.
+A job consists of a number of steps which consists of a number of operation. The entire data model explanation is available [http://www.molgenis.org/wiki/ComputeDataModel here]. Every job is running in the separate thread ([http://www.molgenis.org/svn/sandbox/molgenis_processing/3.3.galaxy/ScriptbasedComputePlatform/src/scriptserver/PipelineThread.java PipelineThread])   Operation are submitted to a Worker on the cluster in the loop using the gridgain executor service.
+
+{{{
+ExecutorService exec = grid.newGridExecutorService();
+
+int numberOfSteps = pipeline.getNumberOfSteps();
+...
+
+for (int i = 0; i < numberOfSteps; i++)
+{
+     Step step = pipeline.getStep(i);
+
+     for (int j = 0; j < step.getNumberOfScripts(); j++)
+     {
+         Script script = step.getScript(j);
+
+         Future<RemoteResult> future = exec.submit(new RemoteScriptSubmitter(script));
+
+         RemoteResult back = null;
+         try
+         {
+             back = future.get();
+         }
+...
+
+}}}
+