Changes between Version 2 and Version 3 of Laboratory/GridComparisonPartI/GridGain-2.1.1

Timestamp:

12.02.2010 15:18:23 (3 years ago)

Author:

jeremian

Comment:

Two test cases for GridGain

Laboratory/GridComparisonPartI/GridGain-2.1.1

@@ -16 +16 @@
 
  == Code ==
+
+We prepared two versions of the !GridGain test:
+ * with !GridTasks
+ * with !ExecutorService
+
+The first version had some issues with large amount of tasks (known edge-case problem with "siblings" explosion). The second one performed much better with large amount of tasks, but was a little bit slower in other cases.
+
+ === Test case I - using !GridTasks ===
 
 !GridGain operates on the !GridTasks. Executing such tasks is very simple:
@@ -86 +94 @@
 
     return result;
+}
+
+}}}
+
+ === Test case II - using !ExecutorService ===
+
+!GridGain's distributed executor service operates on the Callable/Runnable interfaces. The main work was done in the '''Agent''' class, which implements Callable interface:
+
+{{{
+#!java
+
+public class Agent implements Callable<FastBigInt128>, Serializable {
+    private static final long serialVersionUID = 1L;
+    private String[] imageDesc;
+    private int z;
+
+    public Agent(String[] imageDesc, int z) {
+        this.imageDesc = imageDesc;
+        this.z = z;
+    }
+
+    public FastBigInt128 call() {
+        Worker cmbfWorker = new Worker();
+        FastBigInt128 result = cmbfWorker.countInImage(imageDesc);
+        System.out.println("\tResult from task #" + z + ", " + "\tvalue: " + result);
+        return result;
+    }
+}
+
+}}}
+
+In order to perform computations, we had to divide problem into small tasks and submit them into executor service:
+
+{{{
+#!java
+
+for (int i = 1; i <= n; i++) {
+    for (final String[] imageDesc : cmbfWorker.generateImages(i, level)) {
+        Future<FastBigInt128> future = executorService.submit(new Agent(imageDesc, ++count));
+        tasks.add(future);
+    }
+}
+
+}}}
+
+After that we had to gather results:
+
+{{{
+#!java
+
+for (Future<FastBigInt128> w : tasks) {
+    results.add(w.get());
 }