// node-multiprocess exports a singleton and a class to be used
// the default export is the singleton class
import SingletonPool from 'node-multiprocess';
// or
import { SingletonPool } from 'node-multiprocess';
 
// a regular class can be imported like this
import { Pool } from 'node-multiprocess'; 

// Before getting first instance of singleton class, you can set the number of processes 
SingletonPool.setMaxProcesses(4); // default is the number of CPUs on machine
// The timeout can also be adjusted in seconds
SingletonPool.setTimeout(120); // default is 60 seconds
 
const pool = SingletonPool.getInstance();
...
const pool = SingletonPool.getInstance(); // same instance as above

// Number of process can be set either before instantiation or during
// before 
Pool.MAX_PROCESSES = 4; // default is the number of CPUs
// during
const pool = new Pool(4); // both create a pool with four processes
// The timeout can also be adjusted before instantiation
Pool.TIMEOUT = 120; // default is 60 seconds
const secondPool = new Pool();
// ^ Pool will have four processes and a timeout of 120 seconds
// create `secondPool` before killing `pool` will cause their to be four additional worker processes alive

const pool = new Pool(4);
 
function fibSlow(n: number): number {
    if (n <= 0) {
        return 1;
    }
    return fibSlow(n-1) + fibSlow(n-2);
}
 
const promises = []
for (let i = 1; i < 6; i++) {
    const resultPromise = pool.addJob(fibSlow, i);
    promise.push(resultPromise)
}
 
const promisesResults = await Promise.all(promises);
promisesResults.forEach(result => console.log(result));
// 1 2 3 5 8

function addThree(x: number, y: number, z: number): number {
    return x + Y + Z;
}
pool.addJob(addThree, 10, 15, 20);
// Promise<number> => 45
 
function mergeObj(obj1: Object, obj2: Object): Object {
    return {
        ...obj1,
        ...obj2
    };
}
pool.addJob(mergeObj, {a: 'a'}, {b: 'b'});
// Promise<Object> => {a: 'a', b: 'b'}

pool.kill(); // sends SIGINT to all child processes