Check multiple primes at once.

Modified the middleware to track multiple workers for
each number all at the same time. This allows separate
simultaneous evaluation of numbers.

Author: coderkevin

examples/simple/middleware/primesMiddleware.js

@@ -1,37 +1,45 @@
 import { removeQueueNumber, addPrime, addNonPrime } from '../actions/primes';
 
-export const CHECK_NEXT_PRIME = 'CHECK_NEXT_PRIME';
+export const CHECK_PRIMES = 'CHECK_PRIMES';
+
+let workers = {};
 
 function createPrimesMiddleware() {
 	return ( store ) => ( next ) => ( action ) => {
 
 		switch ( action.type ) {
-			case CHECK_NEXT_PRIME:
+			case CHECK_PRIMES:
 				const { queue } = store.getState().primeState;
-				checkNextPrime( queue, store.dispatch );
+				checkPrimes( queue, store.dispatch );
 				return true;
 			default:
 				return next( action );
 		}
 	};
 }
 
-function checkNextPrime( queue, dispatch ) {
+function checkPrimes( queue, dispatch ) {
 	if ( queue.length > 0 ) {
-		const number = queue[0];
-		console.log( 'checking next number ' + number );
-		checkPrime( number ).then(
-			( isPrime ) => {
-				dispatch( removeQueueNumber( number ) );
-				if ( isPrime ) {
-					console.log( 'number ' + number + ' is prime!' );
-					dispatch( addPrime( number ) );
-				} else {
-					console.log( 'number ' + number + ' is not prime!' );
-					dispatch( addNonPrime( number ) );
-				}
+
+		queue.forEach( ( number ) => {
+			if ( ! workers[ number ] ) {
+				console.log( 'checking number ' + number );
+				checkPrime( number ).then(
+					( isPrime ) => {
+						dispatch( removeQueueNumber( number ) );
+						if ( isPrime ) {
+							console.log( 'number ' + number + ' is prime!' );
+							dispatch( addPrime( number ) );
+						} else {
+							console.log( 'number ' + number + ' is not prime!' );
+							dispatch( addNonPrime( number ) );
+						}
+					}
+				);
 			}
-		);
+		}	);
+
+		const number = queue[0];
 	}
 }
 
@@ -41,23 +49,24 @@ function checkPrime( number ) {
 		( resolve, reject ) => {
 			// Create a worker to do the actual mathematical operations.
 			const worker = new Worker( '/static/worker-primes.js' );
+			workers[ number ] = worker;
+			console.log( 'Worker created' );
+			console.log( worker );
 
 			worker.onmessage = function( evt ) {
 				console.log( 'message received from worker.' );
 				console.log( evt );
+				delete workers[ number ];
 				resolve( evt.data );
 			}
 
-			console.log( 'Worker created' );
-			console.log( worker );
-
 			worker.postMessage( Number( number ) );
 		}
 	);
 }
 
-export function checkNextPrimeAction() {
-	return { type: CHECK_NEXT_PRIME };
+export function checkPrimesAction() {
+	return { type: CHECK_PRIMES };
 }
 
 export default createPrimesMiddleware;

examples/simple/triggers/primeStateTriggers.js

@@ -1,6 +1,6 @@
 // TODO: Switch this out with a proper import from the module when it's ready.
 import { addTrigger } from '../../../src';
-import { checkNextPrimeAction } from '../middleware/primesMiddleware';
+import { checkPrimesAction } from '../middleware/primesMiddleware';
 
 const REMOVE_FROM_QUEUE = 'REMOVE_FROM_QUEUE';
 
@@ -16,7 +16,7 @@ export function addQueueTrigger() {
 		queueMatcher,
 		( match ) => {
 			return [
-				checkNextPrimeAction(),
+				checkPrimesAction(),
 				addQueueTrigger(),
 			];
 		}