Tiny library to execute code on multi threads. Result of each thread is resturned as a promise. Processor can use any promise library (see Promise chapter).
- Download the latest release.
- Clone the repo:
git clone https://github.com/jccazeaux/processor.git
. - Install with npm:
npm install promised-processor
.
var t = processor.thread(function(a, b) {
return a + b;
});
thread
function returns an object containing a function exec
. This function will execute the thread. All exec
arguments will be sent to thread function.
t.exec(1, 2);
exec
function returns result of thread function as a promise
.
t.exec(1, 2)
.then(function(res) {
console.log(res); // 3
});
Errors are handled by promise
processor.thread(function() {
throw new Error("I failed");
})
.exec()
.catch(function(message) {
console.log(message); // I failed
});
By default processor
will have a pool of two threads. You can configure this number with config.nbThreads
function
processor.config.nbThreads(4);
Keep in mind it may be useless to configure more threads than the number of cores.
processor
can adapt to these promises library
You may define use any promise library. You just need to define an adapter. This adapter creates a function that creates the promises and takes resolve
and rejects
as parameters.
As an exemple, here is default adapter
function() {
var res;
if (window.Promise) {
res = function(resolve, reject) {
return new window.Promise(resolve, reject);
};
} else if (window.Q) {
res = function(resolve, reject) {
return Q.Promise(resolve, reject);
};
} else {
throw "No recognized promise library nor ES6 Promise. Try to customize with processor.promiseAdapter";
}
return res;
}
To define a new one
processor.config.promiseAdapter(function() {
return function(resolve, reject) {
// Code your adapter here
};
});