executors v0.0.6

Executors - concurrent executors

Java's concurrent executors for JavaScript.

thread pool, or parallel execution limiter.

using ES6 (ES2015) generator function.

INSTALL:

$ npm install executors aa -S

PREPARE:

  var Executors = require('executors');
  var aa = require('aa');

USAGE:

Quick sample code: executors-readme-example.js

$ node executors-readme-example.js

	var Executors = require('executors');
	var aa = require('aa');
	var thunkify = aa.thunkify;
	var promisify = aa.promisify;

	var concurrent = 0;
	function sleep(ms, arg, cb) {
		console.log('++', arg, ++concurrent);
		setTimeout(function () {
			console.log('--', arg, --concurrent);
			cb(null, arg);
		}, ms);
	}

	var delay = thunkify(sleep);
	var wait = promisify(sleep);

	aa(function* main() {
		console.log('\n** a1++ max 1 execution (sequentioal)');
		yield delay(100, 'a1-0');
		yield wait(100, 'a1-1');
		yield delay(100, 'a1-2');
		yield wait(100, 'a1-3');
		console.log('** a1-- max 1 execution (sequentioal)');

		console.log('\n** a4++ max 4 parallel execution');
		yield [delay(100, 'a4-0'), wait(100, 'a4-1'), delay(100, 'a4-2'), wait(100, 'a4-3')];
		console.log('** a4-- max 4 parallel execution');

		console.log('\n** a10++ max 10 parallel execution (no limitter)');
		var par = [];
		for (var i = 0; i < 5; ++i) {
			par.push(delay(100, 'a10-' + (i * 2)));
			par.push(wait(100, 'a10-' + (i * 2 + 1)));
		}
		yield par;
		console.log('** a10-- max 10 parallel execution (no limitter)');

		console.log('\n** a2++ max 2 parallel execution');
		var executor2 = Executors(2);
		var par = [];
		for (var i = 0; i < 5; ++i) {
			par.push(executor2(delay, 100, 'a2-' + (i * 2)));
			par.push(executor2(wait, 100, 'a2-' + (i * 2 + 1)));
		}
		yield par;
		console.log('** a2-- max 2 parallel execution');

		console.log('\n** a3++ max 3 parallel execution');
		var executor3 = Executors(3);
		par = [];
		for (var i = 0; i < 5; ++i) {
			par.push(executor3(delay, 100, 'a3-' + (i * 2)));
			par.push(executor3(wait, 100, 'a3-' + (i * 2 + 1)));
		}
		yield par;
		console.log('** a3-- max 3 parallel execution');
	});

LICENSE:

MIT