Merge pull request #10 from Java-Numerical-Processing/changes/multithreading

implemented parallel executor superclass

Author: evanstella

src/com/evanstella/jnp/math/ElementWiseExecutor.java

@@ -39,43 +39,12 @@
  *
  * @author Evan Stella
  *****************************************************************************/
-public final class ElementWiseExecutor {
+public final class ElementWiseExecutor extends ParallelExecutor {
 
-    public int threadCount;
-    private final ExecutorService executorService;
-
-    // no instances for you
-    public ElementWiseExecutor(int threadCount ) {
-        this.threadCount = threadCount;
-        executorService = Executors.newFixedThreadPool(threadCount);
-    }
-
-    public void shutdown ( ) {
-        executorService.shutdown();
-    }
-
-    //TODO
-    private static class executionWorker implements Runnable {
-        final int startIdx, endIdx;
-        public executionWorker ( int start, int end ) {
-            startIdx = start;
-            endIdx = end;
-        }
-        public void run ( ) {}
+    public ElementWiseExecutor( int threadCount ) {
+        super( threadCount );
     }
 
-
-    private void await ( CountDownLatch count ) {
-        try {
-            count.await();
-        } catch ( InterruptedException e ) {
-            throw new ExecutionInterruptedException(
-                "Parallel execution was interrupted"
-            );
-        }
-    }
-
-
     /**************************************************************************
      * <p>Take the negative of A element wise
      *

src/com/evanstella/jnp/math/Matrix.java

@@ -40,7 +40,7 @@ public final class Matrix {
     // no instances for you
     private Matrix ( ) {}
 
-    private static void validateMatrixFatal ( Numeric N ) {
+    public static void validateMatrixFatal ( Numeric N ) {
         if ( N.shape().length == 2 )
             return;
 

src/com/evanstella/jnp/math/MatrixExecutor.java

@@ -0,0 +1,17 @@
+package com.evanstella.jnp.math;
+
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+
+public final class MatrixExecutor extends ParallelExecutor {
+
+    public MatrixExecutor ( int threadCount ) {
+        super(threadCount);
+    }
+
+
+
+
+
+
+}

src/com/evanstella/jnp/math/ParallelExecutor.java

@@ -0,0 +1,42 @@
+package com.evanstella.jnp.math;
+
+import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+
+public class ParallelExecutor {
+
+    public int threadCount;
+    protected final ExecutorService executorService;
+
+    // no instances for you
+    public ParallelExecutor( int threadCount ) {
+        this.threadCount = threadCount;
+        executorService = Executors.newFixedThreadPool(threadCount);
+    }
+
+    public void shutdown ( ) {
+        executorService.shutdown();
+    }
+
+    //TODO
+    protected static class executionWorker implements Runnable {
+        final int startIdx, endIdx;
+        public executionWorker ( int start, int end ) {
+            startIdx = start;
+            endIdx = end;
+        }
+        public void run ( ) {}
+    }
+
+    protected void await ( CountDownLatch count ) {
+        try {
+            count.await();
+        } catch ( InterruptedException e ) {
+            throw new ExecutionInterruptedException(
+                "Parallel execution was interrupted"
+            );
+        }
+    }
+
+}