Parallel.js初探

今天闲着看了一下Parallel.js。这个库暂时貌似还没有什么中文的介绍（可能暂时用的人都不多吧）。所以就只能上github找它得源码和介绍看看了。貌似它的代码也不多，以后可以深入研究一下。

先简单翻译一下介绍吧：

构造函数

Parallel(data, opts)

这个data是一个你希望操作的数组，数据会保存在内存中直到完成工作，你也可以通过.data访问。你可以对数据进行一系列的操作。不过你的值都必须要序列化成JSON

opts是可选的参数：

　　evalPath指定指向eval.js的路径，具体什么用暂时还没有看懂，各位有知道的可以告诉我。

　　maxWorkers指定最大线程数，默认值是4。

　　synchronous定义当webworks不支持时的操作。

官方的例子：

var p = new Parallel([1, 2, 3, 4, 5]);

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

其它函数：

spawn(fn)

　　这个函数是用来将产生一个新的线程。

fn是一个执行在线程中的函数，这个函数可以获得现在的data并返回修正值。

官方例子：

var p = new Parallel('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 sdrawrof

  return data;
}).then(function (data) {
  console.log(data) // logs sdrawrof
});

map(fn)

　　这个函数用来对所有的数据都创建一个线程（应该不会超过最大规定线程数）

官方例子：

var p = new Parallel([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 appropriately
function fib(n) {
  return n < 2 ? 1 : fib(n - 1) + fib(n - 2);
};

p.map(fib).then(log)

// Logs the first 7 Fibonnaci numbers, woot!

reduce(fn)

官方例子：

var p = new Parallel([0, 1, 2, 3, 4, 5, 6, 7, 8]);

function add(d) { return d[0] + d[1]; }
function factorial(n) { return n < 2 ? 1 : n * factorial(n - 1); }
function log() { console.log(arguments); }

p.require(factorial)

// Approximate e^10
p.map(function (n) { return Math.pow(10, n); }).reduce(add).then(log);

then(success, fail)

这个函数很简单，就是制定了线程执行完成以后的操作。顾名思义success就是成功时的操作，fail是失败时的操作（fail可以不提供）

官方例子：

var p = new Parallel([1, 2, 3]);

function dbl(n) { return n * 2; }

p.map(dbl).map(dbl).map(dbl).then(function (data) {
  console.log(data); // logs [8, 16, 24]
});

// Approximate e^10
p.map(function (n) { return Math.pow(10, n) / factorial(n); }).reduce(add).then(log);

require(state)

如果你有什么需要在主线程和工作线程之间分享的可以使用这个，state可以是字符串也可以是文件名。在使用这个函数的时候要注意构造函数中的可选参数evalPath一定要写上

官方例子：

var p = new Parallel([1, 2, 3], { evalPath: 'https://raw.github.com/adambom/parallel.js/master/lib/eval.js' });

function cubeRoot(n) { return Math.pow(n, 1 / 3); }

// Require a function
p.require(cubeRoot);

// Require a file
p.require('blargh.js');

p.map(function (d) {
  return blargh(20 * cubeRoot(d));
});