Repository files navigation

Parallel.js is a simple library for parallel computing in Javascript, either in Node.js or in the Web Browser.Parallel takes advantage of Web Workers for the web, and child processes for Node.

You can download the raw javascript filehere

Just include it via a script tag in your HTML page

Parallel.js is also available as a node module:

npm install parallel.js

This is the constructor. Use it to new up any parallel jobs. The constructor takes an array of data you want tooperate on. This data will be held in memory until you finish your job, and can be accessed via the.data attributeof your job.

The object returned by theParallel constructor is meant to be chained, so you can produce a chain ofoperations on the provided data.

Arguments

• data: This is the data you wish to operate on. Will often be an array, but the only restrictions are that your values are serializable as JSON.
• options (optional): Some options for your job
  • evalPath (optional): This is the path to the file eval.js. This is required when running in node, and required for some browsers (IE 10) in order to work around cross-domain restrictions for web workers. Defaults to the same location as parallel.js in node environments, andnull in the browser.
  • maxWorkers (optional): The maximum number of permitted worker threads. This will default to 4, or the number of cpus on your computer if you're running node
  • synchronous (optional): If webworkers are not available, whether or not to fall back to synchronous processing usingsetTimeout. Defaults totrue.

Example

varp=newParallel([1,2,3,4,5]);console.log(p.data);// prints [1, 2, 3, 4, 5]

This function will spawn a new process on a worker thread. Pass it the function you want to call. Yourfunction will receive one argument, which is the current data. The value returned from your spawned function willupdate the current data.

Arguments

• fn: A function to execute on a worker thread. Receives the wrapped data as an argument. The value returned will be assigned to the wrapped data.

Example

varp=newParallel('forwards');// Spawn a remote job (we'll see more on how to use then later)p.spawn(function(data){data=data.reverse();console.log(data);// logs sdrawrofreturndata;}).then(function(data){console.log(data)// logs sdrawrof});

Map will apply the supplied function to every element in the wrapped data. Parallel will spawn one worker foreach array element in the data, or the supplied maxWorkers argument. The values returned will be stored forfurther processing.

Arguments

• fn: A function to apply. Receives the wrapped data as an argument. The value returned will be assigned to the wrapped data.

Example

varp=newParallel([0,1,2,3,4,5,6]),log=function(){console.log(arguments);};// One gotcha: anonymous functions cannot be serialzed// If you want to do recursion, make sure the function// is named appropriatelyfunctionfib(n){returnn<2 ?1 :fib(n-1)+fib(n-2);};p.map(fib).then(log)// Logs the first 7 Fibonnaci numbers, woot!

Reduce applies an operation to every member of the wrapped data, and returns a scalar value produced by the operation.Use it for combining the results of a map operation, by summing numbers for example. This takes a reducing function,which gets an argument,data, an array of the stored value, and the current element.

Arguments

• fn: A function to apply. Receives the stored value and current element as argument. The value returned will be stored as the current value for the next iteration. Finally, the current value will be assigned to current data.

Example

varp=newParallel([0,1,2,3,4,5,6,7,8]);functionadd(d){returnd[0]+d[1];}functionfactorial(n){returnn<2 ?1 :n*factorial(n-1);}functionlog(){console.log(arguments);}p.require(factorial)// Approximate e^10p.map(function(n){returnMath.pow(10,n);}).reduce(add).then(log);

The functions given tothen are called after the last requested operation has finished.success receives the resulting data object, whilefail will receive an error object.

Arguments

• success: A function that gets called upon succesful completion. Receives the wrapped data as an argument.
• failure (optional): A function that gets called if the job fails. The function is passed an error object.

Example

varp=newParallel([1,2,3]);functiondbl(n){returnn*2;}p.map(dbl).map(dbl).map(dbl).then(function(data){console.log(data);// logs [8, 16, 24]});// Approximate e^10p.map(function(n){returnMath.pow(10,n)/factorial(n);}).reduce(add).then(log);

If you have state that you want to share between your main thread and the worker threads, this is how. Requiretakes either a string or a function. A string should point to a file name. Note that in order touserequire with a file name as an argument, you have to provide the evalPath property in the optionsobject.

Example

varp=newParallel([1,2,3]);functioncubeRoot(n){returnMath.pow(n,1/3);}// Require a functionp.require(cubeRoot);// Require a filep.require('blargh.js');p.map(function(d){returnblargh(20*cubeRoot(d));});