add: graphs et rushs

2 files changed, 83 insertions, 0 deletions

diff --git a/graphs/java/threadForkJoin/src/main/java/fr/epita/assistants/forkjoin/MyRecursiveTask.java b/graphs/java/threadForkJoin/src/main/java/fr/epita/assistants/forkjoin/MyRecursiveTask.java
new file mode 100644
index 0000000..5934f92
--- /dev/null
+++ b/graphs/java/threadForkJoin/src/main/java/fr/epita/assistants/forkjoin/MyRecursiveTask.java
@@ -0,0 +1,49 @@
+package fr.epita.assistants.forkjoin;
+
+import java.util.concurrent.ForkJoinTask;
+import java.util.concurrent.RecursiveTask;
+
+public class MyRecursiveTask extends RecursiveTask<Double> {
+    final private double[][] matrix;
+    final private int xLowerBound;
+    final private int xUpperBound;
+    final private int yLowerBound;
+    final private int yUpperBound;
+
+    public MyRecursiveTask(double[][] matrix, int xLowerBound, int xUpperBound, int yLowerBound, int yUpperBound) {
+        this.matrix = matrix;
+        this.xLowerBound = xLowerBound;
+        this.xUpperBound = xUpperBound;
+        this.yLowerBound = yLowerBound;
+        this.yUpperBound = yUpperBound;
+    }
+
+    @Override
+    protected Double compute() {
+        if (xUpperBound - xLowerBound <= 5 && yUpperBound - yLowerBound <= 5) {
+            Double avg = 0.0;
+            for (int j = yLowerBound; j < yUpperBound; j++) {
+                for (int i = xLowerBound; i < xUpperBound; i++) {
+                    avg += matrix[j][i];
+                }
+            }
+            if ((xUpperBound - xLowerBound) * (yUpperBound - yLowerBound) == 0)
+                return 0.0;
+            return avg / ((xUpperBound - xLowerBound) * (yUpperBound - yLowerBound));
+        } else {
+            MyRecursiveTask t1 = new MyRecursiveTask(matrix, xLowerBound, xLowerBound + (xUpperBound - xLowerBound) / 2,
+                    yLowerBound, yLowerBound + (yUpperBound - yLowerBound) / 2);
+            MyRecursiveTask t2 = new MyRecursiveTask(matrix, xLowerBound + (xUpperBound - xLowerBound) / 2, xUpperBound,
+                    yLowerBound, yLowerBound + (yUpperBound - yLowerBound) / 2);
+            MyRecursiveTask t3 = new MyRecursiveTask(matrix, xLowerBound, xLowerBound + (xUpperBound - xLowerBound) / 2,
+                    yLowerBound + (yUpperBound - yLowerBound) / 2, yUpperBound);
+            MyRecursiveTask t4 = new MyRecursiveTask(matrix, xLowerBound + (xUpperBound - xLowerBound) / 2, xUpperBound,
+                    yLowerBound + (yUpperBound - yLowerBound) / 2, yUpperBound);
+            t1.fork();
+            t2.fork();
+            t3.fork();
+            t4.fork();
+            return (t1.join() + t2.join() + t3.join() + t4.join()) / 4;
+        }
+    }
+}
\ No newline at end of file
diff --git a/graphs/java/threadForkJoin/src/test/java/fr/epita/assistants/forkjoin/RecursiveTaskTest.java b/graphs/java/threadForkJoin/src/test/java/fr/epita/assistants/forkjoin/RecursiveTaskTest.java
new file mode 100644
index 0000000..c8f6877
--- /dev/null
+++ b/graphs/java/threadForkJoin/src/test/java/fr/epita/assistants/forkjoin/RecursiveTaskTest.java
@@ -0,0 +1,34 @@
+package fr.epita.assistants.forkjoin;
+
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.Timeout;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+
+@Timeout(1)
+public class RecursiveTaskTest {
+    @Test
+    void exampleTest() {
+        // Create a Matrix
+        double[][] matrix = new double[][]{
+                new double[]{10, 52, 100, 50, 74, 25},
+                new double[]{10, 52, 100, 50, 74, 25},
+                new double[]{10, 52, 100, 50, 74, 25},
+                new double[]{10, 52, 100, 50, 74, 25},
+                new double[]{10, 52, 100, 50, 74, 25},
+                new double[]{10, 52, 100, 50, 74, 25}
+        };
+        double expected = 51.83;
+
+        MyRecursiveTask mrt = new MyRecursiveTask(matrix, 0, matrix[0].length, 0, matrix.length);
+
+        // Fork and join task
+        mrt.fork();
+        double got = mrt.join();
+
+        // Need delta because of 'double' type
+        assertEquals(expected, got, 0.01);
+    }
+
+    // Write your tests here ...
+}