Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More →
Socket
Socket
Sign inDemoInstall

workerpool

Package Overview
Dependencies
Maintainers
2
Versions
63
Alerts
File Explorer

Advanced tools

License
Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

workerpool - npm Package Compare versions

Comparing version 6.0.4 to 6.1.0

135

dist/worker.js

@@ -7,4 +7,4 @@ /**

*
* @version 6.0.4
* @date 2021-01-16
* @version 6.1.0
* @date 2021-01-31
*

@@ -27,9 +27,11 @@ * @license

/******/ (() => { // webpackBootstrap
/******/ (function() { // webpackBootstrap
/******/ var __webpack_modules__ = ({
/***/ 736:
/***/ ((__unused_webpack_module, exports) => {
/***/ 744:
/***/ (function(__unused_webpack_module, exports) {
var __webpack_unused_export__;
function _typeof(obj) { "@babel/helpers - typeof"; if (typeof Symbol === "function" && typeof Symbol.iterator === "symbol") { _typeof = function _typeof(obj) { return typeof obj; }; } else { _typeof = function _typeof(obj) { return obj && typeof Symbol === "function" && obj.constructor === Symbol && obj !== Symbol.prototype ? "symbol" : typeof obj; }; } return _typeof(obj); }
/**

@@ -39,10 +41,4 @@ * worker must be started as a child process or a web worker.

*/
// source of inspiration: https://github.com/sindresorhus/require-fool-webpack
var requireFoolWebpack = eval(
'typeof require !== \'undefined\'' +
' ? require' +
' : function (module) { throw new Error(\'Module " + module + " not found.\') }'
);
var requireFoolWebpack = eval('typeof require !== \'undefined\'' + ' ? require' + ' : function (module) { throw new Error(\'Module " + module + " not found.\') }');
/**

@@ -52,11 +48,11 @@ * Special message sent by parent which causes the worker to terminate itself.

*/
var TERMINATE_METHOD_ID = '__workerpool-terminate__';
// var nodeOSPlatform = require('./environment').nodeOSPlatform;
var TERMINATE_METHOD_ID = '__workerpool-terminate__'; // var nodeOSPlatform = require('./environment').nodeOSPlatform;
// create a worker API for sending and receiving messages which works both on
// node.js and in the browser
var worker = {
exit: function() {}
exit: function exit() {}
};
if (typeof self !== 'undefined' && typeof postMessage === 'function' && typeof addEventListener === 'function') {

@@ -67,17 +63,16 @@ // worker in the browser

callback(message.data);
})
});
};
worker.send = function (message) {
postMessage(message);
};
}
else if (typeof process !== 'undefined') {
} else if (typeof process !== 'undefined') {
// node.js
var WorkerThreads;
var WorkerThreads;
try {
WorkerThreads = requireFoolWebpack('worker_threads');
} catch(error) {
if (typeof error === 'object' && error !== null && error.code === 'MODULE_NOT_FOUND') {
// no worker_threads, fallback to sub-process based workers
} catch (error) {
if (_typeof(error) === 'object' && error !== null && error.code === 'MODULE_NOT_FOUND') {// no worker_threads, fallback to sub-process based workers
} else {

@@ -89,5 +84,5 @@ throw error;

if (WorkerThreads &&
/* if there is a parentPort, we are in a WorkerThread */
WorkerThreads.parentPort !== null) {
var parentPort = WorkerThreads.parentPort;
/* if there is a parentPort, we are in a WorkerThread */
WorkerThreads.parentPort !== null) {
var parentPort = WorkerThreads.parentPort;
worker.send = parentPort.postMessage.bind(parentPort);

@@ -97,4 +92,4 @@ worker.on = parentPort.on.bind(parentPort);

worker.on = process.on.bind(process);
worker.send = process.send.bind(process);
// register disconnect handler only for subprocess worker to exit when parent is killed unexpectedly
worker.send = process.send.bind(process); // register disconnect handler only for subprocess worker to exit when parent is killed unexpectedly
worker.on('disconnect', function () {

@@ -105,4 +100,3 @@ process.exit(1);

}
}
else {
} else {
throw new Error('Script must be executed as a worker');

@@ -112,10 +106,9 @@ }

function convertError(error) {
return Object.getOwnPropertyNames(error).reduce(function(product, name) {
return Object.getOwnPropertyNames(error).reduce(function (product, name) {
return Object.defineProperty(product, name, {
value: error[name],
enumerable: true
value: error[name],
enumerable: true
});
}, {});
}
/**

@@ -127,9 +120,10 @@ * Test whether a value is a Promise via duck typing.

*/
function isPromise(value) {
return value && (typeof value.then === 'function') && (typeof value.catch === 'function');
}
return value && typeof value.then === 'function' && typeof value["catch"] === 'function';
} // functions available externally
// functions available externally
worker.methods = {};
/**

@@ -141,2 +135,3 @@ * Execute a function with provided arguments

*/
worker.methods.run = function run(fn, args) {

@@ -146,3 +141,2 @@ var f = new Function('return (' + fn + ').apply(null, arguments);');

};
/**

@@ -152,2 +146,4 @@ * Get a list with methods available on this worker

*/
worker.methods.methods = function methods() {

@@ -157,2 +153,3 @@ return Object.keys(worker.methods);

var currentRequestId = null;
worker.on('message', function (request) {

@@ -162,2 +159,3 @@ if (request === TERMINATE_METHOD_ID) {

}
try {

@@ -167,3 +165,4 @@ var method = worker.methods[request.method];

if (method) {
// execute the function
currentRequestId = request.id; // execute the function
var result = method.apply(method, request.params);

@@ -173,19 +172,18 @@

// promise returned, resolve this and then return
result
.then(function (result) {
worker.send({
id: request.id,
result: result,
error: null
});
})
.catch(function (err) {
worker.send({
id: request.id,
result: null,
error: convertError(err)
});
});
}
else {
result.then(function (result) {
worker.send({
id: request.id,
result: result,
error: null
});
currentRequestId = null;
})["catch"](function (err) {
worker.send({
id: request.id,
result: null,
error: convertError(err)
});
currentRequestId = null;
});
} else {
// immediate result

@@ -197,9 +195,8 @@ worker.send({

});
currentRequestId = null;
}
}
else {
} else {
throw new Error('Unknown method "' + request.method + '"');
}
}
catch (err) {
} catch (err) {
worker.send({

@@ -212,3 +209,2 @@ id: request.id,

});
/**

@@ -218,4 +214,4 @@ * Register methods to the worker

*/
worker.register = function (methods) {
if (methods) {

@@ -230,3 +226,12 @@ for (var name in methods) {

worker.send('ready');
};
worker.emit = function (payload) {
if (currentRequestId) {
worker.send({
id: currentRequestId,
isEvent: true,
payload: payload
});
}
};

@@ -236,5 +241,5 @@

__webpack_unused_export__ = worker.register;
__webpack_unused_export__ = worker.emit;
}
/***/ })

@@ -270,3 +275,3 @@

/******/ // Load entry module
/******/ __webpack_require__(736);
/******/ __webpack_require__(744);
/******/ // This entry module used 'exports' so it can't be inlined

@@ -273,0 +278,0 @@ /******/ })()

875

dist/workerpool.js

@@ -7,4 +7,4 @@ /**

*
* @version 6.0.4
* @date 2021-01-16
* @version 6.1.0
* @date 2021-01-31
*

@@ -37,12 +37,16 @@ * @license

})((typeof self !== 'undefined' ? self : this), function() {
return /******/ (() => { // webpackBootstrap
return /******/ (function() { // webpackBootstrap
/******/ var __webpack_modules__ = ({
/***/ 542:
/***/ ((module, __unused_webpack_exports, __webpack_require__) => {
/***/ 345:
/***/ (function(module, __unused_webpack_exports, __webpack_require__) {
var Promise = __webpack_require__(514);
var WorkerHandler = __webpack_require__(547);
var environment = __webpack_require__(735);
var DebugPortAllocator = __webpack_require__(530);
var Promise = __webpack_require__(219);
var WorkerHandler = __webpack_require__(751);
var environment = __webpack_require__(828);
var DebugPortAllocator = __webpack_require__(833);
var DEBUG_PORT_ALLOCATOR = new DebugPortAllocator();

@@ -55,7 +59,7 @@ /**

*/
function Pool(script, options) {
if (typeof script === 'string') {
this.script = script || null;
}
else {
} else {
this.script = null;

@@ -65,20 +69,18 @@ options = script;

this.workers = []; // queue with all workers
this.tasks = []; // queue with tasks awaiting execution
this.workers = []; // queue with all workers
this.tasks = []; // queue with tasks awaiting execution
options = options || {};
this.forkArgs = options.forkArgs || [];
this.forkOpts = options.forkOpts || {};
this.debugPortStart = (options.debugPortStart || 43210);
this.debugPortStart = options.debugPortStart || 43210;
this.nodeWorker = options.nodeWorker;
this.workerType = options.workerType || options.nodeWorker || 'auto'
this.maxQueueSize = options.maxQueueSize || Infinity;
this.workerType = options.workerType || options.nodeWorker || 'auto';
this.maxQueueSize = options.maxQueueSize || Infinity; // configuration
// configuration
if (options && 'maxWorkers' in options) {
validateMaxWorkers(options.maxWorkers);
this.maxWorkers = options.maxWorkers;
}
else {
} else {
this.maxWorkers = Math.max((environment.cpus || 4) - 1, 1);

@@ -88,3 +90,3 @@ }

if (options && 'minWorkers' in options) {
if(options.minWorkers === 'max') {
if (options.minWorkers === 'max') {
this.minWorkers = this.maxWorkers;

@@ -94,4 +96,5 @@ } else {

this.minWorkers = options.minWorkers;
this.maxWorkers = Math.max(this.minWorkers, this.maxWorkers); // in case minWorkers is higher than maxWorkers
this.maxWorkers = Math.max(this.minWorkers, this.maxWorkers); // in case minWorkers is higher than maxWorkers
}
this._ensureMinWorkers();

@@ -102,3 +105,2 @@ }

if (this.workerType === 'thread') {

@@ -108,4 +110,2 @@ WorkerHandler.ensureWorkerThreads();

}
/**

@@ -140,5 +140,8 @@ * Execute a function on a worker.

* @param {Array} [params] Function arguments applied when calling the function
* @param {ExecOptions} [options] Options object
* @return {Promise.<*, Error>} result
*/
Pool.prototype.exec = function (method, params) {
Pool.prototype.exec = function (method, params, options) {
// validate type of arguments

@@ -154,18 +157,19 @@ if (params && !Array.isArray(params)) {

throw new Error('Max queue size of ' + this.maxQueueSize + ' reached');
}
} // add a new task to the queue
// add a new task to the queue
var tasks = this.tasks;
var task = {
method: method,
params: params,
method: method,
params: params,
resolver: resolver,
timeout: null
timeout: null,
options: options
};
tasks.push(task);
tasks.push(task); // replace the timeout method of the Promise with our own,
// which starts the timer as soon as the task is actually started
// replace the timeout method of the Promise with our own,
// which starts the timer as soon as the task is actually started
var originalTimeout = resolver.promise.timeout;
resolver.promise.timeout = function timeout (delay) {
resolver.promise.timeout = function timeout(delay) {
if (tasks.indexOf(task) !== -1) {

@@ -175,23 +179,19 @@ // task is still queued -> start the timer later on

return resolver.promise;
}
else {
} else {
// task is already being executed -> start timer immediately
return originalTimeout.call(resolver.promise, delay);
}
};
}; // trigger task execution
// trigger task execution
this._next();
return resolver.promise;
}
else if (typeof method === 'function') {
} else if (typeof method === 'function') {
// send stringified function and function arguments to worker
return this.exec('run', [String(method), params]);
}
else {
} else {
throw new TypeError('Function or string expected as argument "method"');
}
};
/**

@@ -203,2 +203,4 @@ * Create a proxy for current worker. Returns an object containing all

*/
Pool.prototype.proxy = function () {

@@ -210,16 +212,12 @@ if (arguments.length > 0) {

var pool = this;
return this.exec('methods')
.then(function (methods) {
var proxy = {};
methods.forEach(function (method) {
proxy[method] = function () {
return pool.exec(method, Array.prototype.slice.call(arguments));
}
});
return proxy;
});
return this.exec('methods').then(function (methods) {
var proxy = {};
methods.forEach(function (method) {
proxy[method] = function () {
return pool.exec(method, Array.prototype.slice.call(arguments));
};
});
return proxy;
});
};
/**

@@ -235,2 +233,3 @@ * Creates new array with the results of calling a provided callback function

*/
/* TODO: implement map

@@ -246,28 +245,27 @@ Pool.prototype.map = function (array, callback) {

*/
Pool.prototype._next = function () {
if (this.tasks.length > 0) {
// there are tasks in the queue
// find an available worker
var worker = this._getWorker();
if (worker) {
// get the first task from the queue
var me = this;
var task = this.tasks.shift();
var task = this.tasks.shift(); // check if the task is still pending (and not cancelled -> promise rejected)
// check if the task is still pending (and not cancelled -> promise rejected)
if (task.resolver.promise.pending) {
// send the request to the worker
var promise = worker.exec(task.method, task.params, task.resolver)
.then(me._boundNext)
.catch(function () {
// if the worker crashed and terminated, remove it from the pool
if (worker.terminated) {
return me._removeWorker(worker);
}
}).then(function() {
me._next(); // trigger next task in the queue
});
var promise = worker.exec(task.method, task.params, task.resolver, task.options).then(me._boundNext)["catch"](function () {
// if the worker crashed and terminated, remove it from the pool
if (worker.terminated) {
return me._removeWorker(worker);
}
}).then(function () {
me._next(); // trigger next task in the queue
// start queued timer now
}); // start queued timer now
if (typeof task.timeout === 'number') {

@@ -283,3 +281,2 @@ promise.timeout(task.timeout);

};
/**

@@ -294,7 +291,11 @@ * Get an available worker. If no worker is available and the maximum number

*/
Pool.prototype._getWorker = function() {
Pool.prototype._getWorker = function () {
// find a non-busy worker
var workers = this.workers;
for (var i = 0; i < workers.length; i++) {
var worker = workers[i];
if (worker.busy() === false) {

@@ -314,5 +315,4 @@ return worker;

};
/**
* Remove a worker from the pool.
* Remove a worker from the pool.
* Attempts to terminate worker if not already terminated, and ensures the minimum

@@ -324,11 +324,15 @@ * pool size is met.

*/
Pool.prototype._removeWorker = function(worker) {
DEBUG_PORT_ALLOCATOR.releasePort(worker.debugPort);
// _removeWorker will call this, but we need it to be removed synchronously
this._removeWorkerFromList(worker);
// If minWorkers set, spin up new workers to replace the crashed ones
this._ensureMinWorkers();
// terminate the worker (if not already terminated)
return new Promise(function(resolve, reject) {
worker.terminate(false, function(err) {
Pool.prototype._removeWorker = function (worker) {
DEBUG_PORT_ALLOCATOR.releasePort(worker.debugPort); // _removeWorker will call this, but we need it to be removed synchronously
this._removeWorkerFromList(worker); // If minWorkers set, spin up new workers to replace the crashed ones
this._ensureMinWorkers(); // terminate the worker (if not already terminated)
return new Promise(function (resolve, reject) {
worker.terminate(false, function (err) {
if (err) {

@@ -342,3 +346,2 @@ reject(err);

};
/**

@@ -349,5 +352,8 @@ * Remove a worker from the pool list.

*/
Pool.prototype._removeWorkerFromList = function(worker) {
Pool.prototype._removeWorkerFromList = function (worker) {
// remove from the list with workers
var index = this.workers.indexOf(worker);
if (index !== -1) {

@@ -357,3 +363,2 @@ this.workers.splice(index, 1);

};
/**

@@ -369,2 +374,4 @@ * Close all active workers. Tasks currently being executed will be finished first.

*/
Pool.prototype.terminate = function (force, timeout) {

@@ -377,12 +384,11 @@ // cancel any pending tasks

var f = function (worker) {
var f = function f(worker) {
this._removeWorkerFromList(worker);
};
var removeWorker = f.bind(this);
var promises = [];
var workers = this.workers.slice();
workers.forEach(function (worker) {
var termPromise = worker.terminateAndNotify(force, timeout)
.then(removeWorker);
var termPromise = worker.terminateAndNotify(force, timeout).then(removeWorker);
promises.push(termPromise);

@@ -392,3 +398,2 @@ });

};
/**

@@ -398,2 +403,4 @@ * Retrieve statistics on tasks and workers.

*/
Pool.prototype.stats = function () {

@@ -404,13 +411,10 @@ var totalWorkers = this.workers.length;

}).length;
return {
totalWorkers: totalWorkers,
busyWorkers: busyWorkers,
idleWorkers: totalWorkers - busyWorkers,
pendingTasks: this.tasks.length,
activeTasks: busyWorkers
totalWorkers: totalWorkers,
busyWorkers: busyWorkers,
idleWorkers: totalWorkers - busyWorkers,
pendingTasks: this.tasks.length,
activeTasks: busyWorkers
};
};
/**

@@ -420,5 +424,7 @@ * Ensures that a minimum of minWorkers is up and running

*/
Pool.prototype._ensureMinWorkers = function() {
Pool.prototype._ensureMinWorkers = function () {
if (this.minWorkers) {
for(var i = this.workers.length; i < this.minWorkers; i++) {
for (var i = this.workers.length; i < this.minWorkers; i++) {
this.workers.push(this._createWorkerHandler());

@@ -428,3 +434,2 @@ }

};
/**

@@ -435,2 +440,4 @@ * Helper function to create a new WorkerHandler and pass all options.

*/
Pool.prototype._createWorkerHandler = function () {

@@ -443,4 +450,3 @@ return new WorkerHandler(this.script, {

});
}
};
/**

@@ -451,2 +457,4 @@ * Ensure that the maxWorkers option is an integer >= 1

*/
function validateMaxWorkers(maxWorkers) {

@@ -457,3 +465,2 @@ if (!isNumber(maxWorkers) || !isInteger(maxWorkers) || maxWorkers < 1) {

}
/**

@@ -464,2 +471,4 @@ * Ensure that the minWorkers option is an integer >= 0

*/
function validateMinWorkers(minWorkers) {

@@ -470,3 +479,2 @@ if (!isNumber(minWorkers) || !isInteger(minWorkers) || minWorkers < 0) {

}
/**

@@ -477,6 +485,7 @@ * Test whether a variable is a number

*/
function isNumber(value) {
return typeof value === 'number';
}
/**

@@ -487,2 +496,4 @@ * Test whether a number is an integer

*/
function isInteger(value) {

@@ -494,11 +505,9 @@ return Math.round(value) == value;

/***/ }),
/***/ 514:
/***/ ((module) => {
/***/ 219:
/***/ (function(module) {
"use strict";
/**

@@ -512,2 +521,3 @@ * Promise

*/
function Promise(handler, parent) {

@@ -525,9 +535,7 @@ var me = this;

var _onSuccess = [];
var _onFail = [];
var _onFail = []; // status
// status
this.resolved = false;
this.rejected = false;
this.pending = true;
/**

@@ -540,7 +548,8 @@ * Process onSuccess and onFail callbacks: add them to the queue.

*/
var _process = function (onSuccess, onFail) {
var _process = function _process(onSuccess, onFail) {
_onSuccess.push(onSuccess);
_onFail.push(onFail);
};
/**

@@ -552,6 +561,8 @@ * Add an onSuccess callback and optionally an onFail callback to the Promise

*/
this.then = function (onSuccess, onFail) {
return new Promise(function (resolve, reject) {
var s = onSuccess ? _then(onSuccess, resolve, reject) : resolve;
var f = onFail ? _then(onFail, resolve, reject) : reject;
var f = onFail ? _then(onFail, resolve, reject) : reject;

@@ -561,3 +572,2 @@ _process(s, f);

};
/**

@@ -568,3 +578,5 @@ * Resolve the promise

*/
var _resolve = function (result) {
var _resolve2 = function _resolve(result) {
// update status

@@ -579,11 +591,10 @@ me.resolved = true;

_process = function (onSuccess, onFail) {
_process = function _process(onSuccess, onFail) {
onSuccess(result);
};
_resolve = _reject = function () { };
_resolve2 = _reject2 = function _reject() {};
return me;
};
/**

@@ -594,3 +605,5 @@ * Reject the promise

*/
var _reject = function (error) {
var _reject2 = function _reject(error) {
// update status

@@ -605,11 +618,10 @@ me.resolved = false;

_process = function (onSuccess, onFail) {
_process = function _process(onSuccess, onFail) {
onFail(error);
};
_resolve = _reject = function () { }
_resolve2 = _reject2 = function _reject() {};
return me;
};
/**

@@ -619,13 +631,13 @@ * Cancel te promise. This will reject the promise with a CancellationError

*/
this.cancel = function () {
if (parent) {
parent.cancel();
} else {
_reject2(new CancellationError());
}
else {
_reject(new CancellationError());
}
return me;
};
/**

@@ -638,11 +650,11 @@ * Set a timeout for the promise. If the promise is not resolved within

*/
this.timeout = function (delay) {
if (parent) {
parent.timeout(delay);
}
else {
} else {
var timer = setTimeout(function () {
_reject(new TimeoutError('Promise timed out after ' + delay + ' ms'));
_reject2(new TimeoutError('Promise timed out after ' + delay + ' ms'));
}, delay);
me.always(function () {

@@ -654,12 +666,11 @@ clearTimeout(timer);

return me;
};
}; // attach handler passing the resolve and reject functions
// attach handler passing the resolve and reject functions
handler(function (result) {
_resolve(result);
_resolve2(result);
}, function (error) {
_reject(error);
_reject2(error);
});
}
/**

@@ -673,2 +684,4 @@ * Execute given callback, then call resolve/reject based on the returned result

*/
function _then(callback, resolve, reject) {

@@ -678,16 +691,14 @@ return function (result) {

var res = callback(result);
if (res && typeof res.then === 'function' && typeof res['catch'] === 'function') {
// method returned a promise
res.then(resolve, reject);
}
else {
} else {
resolve(res);
}
}
catch (error) {
} catch (error) {
reject(error);
}
}
};
}
/**

@@ -698,7 +709,7 @@ * Add an onFail callback to the Promise

*/
Promise.prototype['catch'] = function (onFail) {
return this.then(null, onFail);
};
// TODO: add support for Promise.catch(Error, callback)
}; // TODO: add support for Promise.catch(Error, callback)
// TODO: add support for Promise.catch(Error, Error, callback)

@@ -711,6 +722,7 @@

*/
Promise.prototype.always = function (fn) {
return this.then(fn, fn);
};
/**

@@ -722,3 +734,5 @@ * Create a promise which resolves when all provided promises are resolved,

*/
Promise.all = function (promises){
Promise.all = function (promises) {
return new Promise(function (resolve, reject) {

@@ -733,2 +747,3 @@ var remaining = promises.length,

remaining--;
if (remaining == 0) {

@@ -742,4 +757,3 @@ resolve(results);

});
}
else {
} else {
resolve(results);

@@ -749,3 +763,2 @@ }

};
/**

@@ -755,5 +768,6 @@ * Create a promise resolver

*/
Promise.defer = function () {
var resolver = {};
resolver.promise = new Promise(function (resolve, reject) {

@@ -763,6 +777,4 @@ resolver.resolve = resolve;

});
return resolver;
};
/**

@@ -773,5 +785,7 @@ * Create a cancellation error

*/
function CancellationError(message) {
this.message = message || 'promise cancelled';
this.stack = (new Error()).stack;
this.stack = new Error().stack;
}

@@ -782,6 +796,3 @@

CancellationError.prototype.name = 'CancellationError';
Promise.CancellationError = CancellationError;
/**

@@ -792,5 +803,6 @@ * Create a timeout error

*/
function TimeoutError(message) {
this.message = message || 'timeout exceeded';
this.stack = (new Error()).stack;
this.stack = new Error().stack;
}

@@ -801,13 +813,9 @@

TimeoutError.prototype.name = 'TimeoutError';
Promise.TimeoutError = TimeoutError;
module.exports = Promise;
/***/ }),
/***/ 547:
/***/ ((module, __unused_webpack_exports, __webpack_require__) => {
/***/ 751:
/***/ (function(module, __unused_webpack_exports, __webpack_require__) {

@@ -817,6 +825,15 @@ "use strict";

var Promise = __webpack_require__(514);
var environment = __webpack_require__(735);
var requireFoolWebpack = __webpack_require__(981);
function _createForOfIteratorHelper(o, allowArrayLike) { var it; if (typeof Symbol === "undefined" || o[Symbol.iterator] == null) { if (Array.isArray(o) || (it = _unsupportedIterableToArray(o)) || allowArrayLike && o && typeof o.length === "number") { if (it) o = it; var i = 0; var F = function F() {}; return { s: F, n: function n() { if (i >= o.length) return { done: true }; return { done: false, value: o[i++] }; }, e: function e(_e) { throw _e; }, f: F }; } throw new TypeError("Invalid attempt to iterate non-iterable instance.\nIn order to be iterable, non-array objects must have a [Symbol.iterator]() method."); } var normalCompletion = true, didErr = false, err; return { s: function s() { it = o[Symbol.iterator](); }, n: function n() { var step = it.next(); normalCompletion = step.done; return step; }, e: function e(_e2) { didErr = true; err = _e2; }, f: function f() { try { if (!normalCompletion && it["return"] != null) it["return"](); } finally { if (didErr) throw err; } } }; }
function _unsupportedIterableToArray(o, minLen) { if (!o) return; if (typeof o === "string") return _arrayLikeToArray(o, minLen); var n = Object.prototype.toString.call(o).slice(8, -1); if (n === "Object" && o.constructor) n = o.constructor.name; if (n === "Map" || n === "Set") return Array.from(o); if (n === "Arguments" || /^(?:Ui|I)nt(?:8|16|32)(?:Clamped)?Array$/.test(n)) return _arrayLikeToArray(o, minLen); }
function _arrayLikeToArray(arr, len) { if (len == null || len > arr.length) len = arr.length; for (var i = 0, arr2 = new Array(len); i < len; i++) { arr2[i] = arr[i]; } return arr2; }
function _typeof(obj) { "@babel/helpers - typeof"; if (typeof Symbol === "function" && typeof Symbol.iterator === "symbol") { _typeof = function _typeof(obj) { return typeof obj; }; } else { _typeof = function _typeof(obj) { return obj && typeof Symbol === "function" && obj.constructor === Symbol && obj !== Symbol.prototype ? "symbol" : typeof obj; }; } return _typeof(obj); }
var Promise = __webpack_require__(219);
var environment = __webpack_require__(828);
var requireFoolWebpack = __webpack_require__(397);
/**

@@ -826,4 +843,5 @@ * Special message sent by parent which causes a child process worker to terminate itself.

*/
var TERMINATE_METHOD_ID = '__workerpool-terminate__';
/**

@@ -833,17 +851,19 @@ * If sending `TERMINATE_METHOD_ID` does not cause the child process to exit in this many milliseconds,

*/
var CHILD_PROCESS_EXIT_TIMEOUT = 1000;
function ensureWorkerThreads() {
var WorkerThreads = tryRequireWorkerThreads()
var WorkerThreads = tryRequireWorkerThreads();
if (!WorkerThreads) {
throw new Error('WorkerPool: workerType = \'thread\' is not supported, Node >= 11.7.0 required')
throw new Error('WorkerPool: workerType = \'thread\' is not supported, Node >= 11.7.0 required');
}
return WorkerThreads;
}
} // check whether Worker is supported by the browser
// check whether Worker is supported by the browser
function ensureWebWorker() {
// Workaround for a bug in PhantomJS (Or QtWebkit): https://github.com/ariya/phantomjs/issues/14534
if (typeof Worker !== 'function' && (typeof Worker !== 'object' || typeof Worker.prototype.constructor !== 'function')) {
if (typeof Worker !== 'function' && ((typeof Worker === "undefined" ? "undefined" : _typeof(Worker)) !== 'object' || typeof Worker.prototype.constructor !== 'function')) {
throw new Error('WorkerPool: Web Workers not supported');

@@ -856,4 +876,4 @@ }

return requireFoolWebpack('worker_threads');
} catch(error) {
if (typeof error === 'object' && error !== null && error.code === 'MODULE_NOT_FOUND') {
} catch (error) {
if (_typeof(error) === 'object' && error !== null && error.code === 'MODULE_NOT_FOUND') {
// no worker_threads available (old version of node.js)

@@ -865,5 +885,5 @@ return null;

}
}
} // get the default worker script
// get the default worker script
function getDefaultWorker() {

@@ -875,11 +895,13 @@ if (environment.platform === 'browser') {

}
if (!window.URL || typeof window.URL.createObjectURL !== 'function') {
throw new Error('URL.createObjectURL not supported by the browser');
}
} // use embedded worker.js
// use embedded worker.js
var blob = new Blob([__webpack_require__(241)], {type: 'text/javascript'});
var blob = new Blob([__webpack_require__(670)], {
type: 'text/javascript'
});
return window.URL.createObjectURL(blob);
}
else {
} else {
// use external worker.js in current directory

@@ -891,17 +913,22 @@ return __dirname + '/worker.js';

function setupWorker(script, options) {
if (options.workerType === 'web') { // browser only
if (options.workerType === 'web') {
// browser only
ensureWebWorker();
return setupBrowserWorker(script, Worker);
} else if (options.workerType === 'thread') { // node.js only
} else if (options.workerType === 'thread') {
// node.js only
WorkerThreads = ensureWorkerThreads();
return setupWorkerThreadWorker(script, WorkerThreads);
} else if (options.workerType === 'process' || !options.workerType) { // node.js only
} else if (options.workerType === 'process' || !options.workerType) {
// node.js only
return setupProcessWorker(script, resolveForkOptions(options), requireFoolWebpack('child_process'));
} else { // options.workerType === 'auto' or undefined
} else {
// options.workerType === 'auto' or undefined
if (environment.platform === 'browser') {
ensureWebWorker();
return setupBrowserWorker(script, Worker);
}
else { // environment.platform === 'node'
} else {
// environment.platform === 'node'
var WorkerThreads = tryRequireWorkerThreads();
if (WorkerThreads) {

@@ -919,5 +946,4 @@ return setupWorkerThreadWorker(script, WorkerThreads);

var worker = new Worker(script);
worker.isBrowserWorker = true; // add node.js API to the web worker
worker.isBrowserWorker = true;
// add node.js API to the web worker
worker.on = function (event, callback) {

@@ -928,5 +954,7 @@ this.addEventListener(event, function (message) {

};
worker.send = function (message) {
this.postMessage(message);
};
return worker;

@@ -937,12 +965,14 @@ }

var worker = new WorkerThreads.Worker(script, {
stdout: false, // automatically pipe worker.STDOUT to process.STDOUT
stderr: false // automatically pipe worker.STDERR to process.STDERR
stdout: false,
// automatically pipe worker.STDOUT to process.STDOUT
stderr: false // automatically pipe worker.STDERR to process.STDERR
});
worker.isWorkerThread = true;
// make the worker mimic a child_process
worker.send = function(message) {
worker.isWorkerThread = true; // make the worker mimic a child_process
worker.send = function (message) {
this.postMessage(message);
};
worker.kill = function() {
worker.kill = function () {
this.terminate();

@@ -952,3 +982,3 @@ return true;

worker.disconnect = function() {
worker.disconnect = function () {
this.terminate();

@@ -962,21 +992,15 @@ };

// no WorkerThreads, fallback to sub-process based workers
var worker = child_process.fork(
script,
options.forkArgs,
options.forkOpts
);
var worker = child_process.fork(script, options.forkArgs, options.forkOpts);
worker.isChildProcess = true;
return worker;
}
} // add debug flags to child processes if the node inspector is active
// add debug flags to child processes if the node inspector is active
function resolveForkOptions(opts) {
opts = opts || {};
var processExecArgv = process.execArgv.join(' ');
var inspectorActive = processExecArgv.indexOf('--inspect') !== -1;
var debugBrk = processExecArgv.indexOf('--debug-brk') !== -1;
var execArgv = [];
var execArgv = [];
if (inspectorActive) {

@@ -990,17 +1014,14 @@ execArgv.push('--inspect=' + opts.debugPort);

process.execArgv.forEach(function(arg) {
process.execArgv.forEach(function (arg) {
if (arg.indexOf('--max-old-space-size') > -1) {
execArgv.push(arg)
execArgv.push(arg);
}
})
});
return Object.assign({}, opts, {
forkArgs: opts.forkArgs,
forkOpts: Object.assign({}, opts.forkOpts, {
execArgv: (opts.forkOpts && opts.forkOpts.execArgv || [])
.concat(execArgv)
execArgv: (opts.forkOpts && opts.forkOpts.execArgv || []).concat(execArgv)
})
});
}
/**

@@ -1011,13 +1032,14 @@ * Converts a serialized error to Error

*/
function objectToError (obj) {
var temp = new Error('')
var props = Object.keys(obj)
function objectToError(obj) {
var temp = new Error('');
var props = Object.keys(obj);
for (var i = 0; i < props.length; i++) {
temp[props[i]] = obj[props[i]]
temp[props[i]] = obj[props[i]];
}
return temp
return temp;
}
/**

@@ -1031,16 +1053,16 @@ * A WorkerHandler controls a single worker. This worker can be a child process

*/
function WorkerHandler(script, _options) {
var me = this;
var options = _options || {};
this.script = script || getDefaultWorker();
this.worker = setupWorker(this.script, options);
this.debugPort = options.debugPort;
this.debugPort = options.debugPort; // The ready message is only sent if the worker.add method is called (And the default script is not used)
// The ready message is only sent if the worker.add method is called (And the default script is not used)
if (!script) {
this.worker.ready = true;
}
} // queue for requests that are received before the worker is ready
// queue for requests that are received before the worker is ready
this.requestQueue = [];

@@ -1055,24 +1077,28 @@ this.worker.on('message', function (response) {

var task = me.processing[id];
if (task !== undefined) {
// remove the task from the queue
delete me.processing[id];
if (response.isEvent) {
if (task.options && typeof task.options.on === 'function') {
task.options.on(response.payload);
}
} else {
// remove the task from the queue
delete me.processing[id]; // test if we need to terminate
// test if we need to terminate
if (me.terminating === true) {
// complete worker termination if all tasks are finished
me.terminate();
}
if (me.terminating === true) {
// complete worker termination if all tasks are finished
me.terminate();
} // resolve the task's promise
// resolve the task's promise
if (response.error) {
task.resolver.reject(objectToError(response.error));
if (response.error) {
task.resolver.reject(objectToError(response.error));
} else {
task.resolver.resolve(response.result);
}
}
else {
task.resolver.resolve(response.result);
}
}
}
});
}); // reject all running tasks on worker error
// reject all running tasks on worker error
function onError(error) {

@@ -1086,31 +1112,37 @@ me.terminated = true;

}
me.processing = Object.create(null);
}
} // send all queued requests to worker
// send all queued requests to worker
function dispatchQueuedRequests()
{
me.requestQueue.forEach(me.worker.send.bind(me.worker));
me.requestQueue = [];
function dispatchQueuedRequests() {
var _iterator = _createForOfIteratorHelper(me.requestQueue.splice(0)),
_step;
try {
for (_iterator.s(); !(_step = _iterator.n()).done;) {
var request = _step.value;
me.worker.send(request);
}
} catch (err) {
_iterator.e(err);
} finally {
_iterator.f();
}
}
var worker = this.worker;
// listen for worker messages error and exit
var worker = this.worker; // listen for worker messages error and exit
this.worker.on('error', onError);
this.worker.on('exit', function (exitCode, signalCode) {
var message = 'Workerpool Worker terminated Unexpectedly\n';
message += ' exitCode: `' + exitCode + '`\n';
message += ' signalCode: `' + signalCode + '`\n';
message += ' workerpool.script: `' + me.script + '`\n';
message += ' spawnArgs: `' + worker.spawnargs + '`\n';
message += ' spawnfile: `' + worker.spawnfile + '`\n'
message += ' stdout: `' + worker.stdout + '`\n'
message += ' stderr: `' + worker.stderr + '`\n'
message += ' workerpool.script: `' + me.script + '`\n';
message += ' spawnArgs: `' + worker.spawnargs + '`\n';
message += ' spawnfile: `' + worker.spawnfile + '`\n';
message += ' stdout: `' + worker.stdout + '`\n';
message += ' stderr: `' + worker.stderr + '`\n';
onError(new Error(message));
});
this.processing = Object.create(null); // queue with tasks currently in progress

@@ -1123,3 +1155,2 @@

}
/**

@@ -1129,6 +1160,7 @@ * Get a list with methods available on the worker.

*/
WorkerHandler.prototype.methods = function () {
return this.exec('methods');
};
/**

@@ -1139,19 +1171,21 @@ * Execute a method with given parameters on the worker

* @param {{resolve: Function, reject: Function}} [resolver]
* @param {ExecOptions} [options]
* @return {Promise.<*, Error>} result
*/
WorkerHandler.prototype.exec = function(method, params, resolver) {
WorkerHandler.prototype.exec = function (method, params, resolver, options) {
if (!resolver) {
resolver = Promise.defer();
}
} // generate a unique id for the task
// generate a unique id for the task
var id = ++this.lastId;
// register a new task as being in progress
var id = ++this.lastId; // register a new task as being in progress
this.processing[id] = {
id: id,
resolver: resolver
};
resolver: resolver,
options: options
}; // build a JSON-RPC request
// build a JSON-RPC request
var request = {

@@ -1170,25 +1204,22 @@ id: id,

this.requestQueue.push(request);
}
} // on cancellation, force the worker to terminate
// on cancellation, force the worker to terminate
var me = this;
return resolver.promise.catch(function (error) {
return resolver.promise["catch"](function (error) {
if (error instanceof Promise.CancellationError || error instanceof Promise.TimeoutError) {
// remove this task from the queue. It is already rejected (hence this
// catch event), and else it will be rejected again when terminating
delete me.processing[id];
delete me.processing[id]; // terminate worker
// terminate worker
return me.terminateAndNotify(true)
.then(function() {
throw error;
}, function(err) {
throw err;
});
return me.terminateAndNotify(true).then(function () {
throw error;
}, function (err) {
throw err;
});
} else {
throw error;
}
})
});
};
/**

@@ -1198,6 +1229,7 @@ * Test whether the worker is working or not

*/
WorkerHandler.prototype.busy = function () {
return Object.keys(this.processing).length > 0;
};
/**

@@ -1211,4 +1243,7 @@ * Terminate the worker.

*/
WorkerHandler.prototype.terminate = function (force, callback) {
var me = this;
if (force) {

@@ -1221,2 +1256,3 @@ // cancel all tasks in progress

}
this.processing = Object.create(null);

@@ -1228,8 +1264,10 @@ }

}
if (!this.busy()) {
// all tasks are finished. kill the worker
var cleanup = function(err) {
var cleanup = function cleanup(err) {
me.terminated = true;
me.worker = null;
me.terminating = false;
if (me.terminationHandler) {

@@ -1240,3 +1278,3 @@ me.terminationHandler(err, me);

}
}
};

@@ -1251,7 +1289,6 @@ if (this.worker) {

if (this.worker.isChildProcess) {
var cleanExitTimeout = setTimeout(function() {
var cleanExitTimeout = setTimeout(function () {
me.worker.kill();
}, CHILD_PROCESS_EXIT_TIMEOUT);
this.worker.once('exit', function() {
this.worker.once('exit', function () {
clearTimeout(cleanExitTimeout);

@@ -1265,3 +1302,3 @@ me.worker.killed = true;

} else {
this.worker.requestQueue.push(TERMINATE_METHOD_ID)
this.worker.requestQueue.push(TERMINATE_METHOD_ID);
}

@@ -1274,15 +1311,15 @@ } else {

}
return;
}
else if (typeof this.worker.terminate === 'function') {
} else if (typeof this.worker.terminate === 'function') {
this.worker.terminate(); // web worker
this.worker.killed = true;
}
else {
} else {
throw new Error('Failed to terminate worker');
}
}
cleanup();
}
else {
} else {
// we can't terminate immediately, there are still tasks being executed

@@ -1292,3 +1329,2 @@ this.terminating = true;

};
/**

@@ -1304,8 +1340,12 @@ * Terminate the worker, returning a Promise that resolves when the termination has been done.

*/
WorkerHandler.prototype.terminateAndNotify = function (force, timeout) {
var resolver = Promise.defer();
if (timeout) {
resolver.promise.timeout = timeout;
}
this.terminate(force, function(err, worker) {
this.terminate(force, function (err, worker) {
if (err) {

@@ -1327,7 +1367,6 @@ resolver.reject(err);

/***/ }),
/***/ 530:
/***/ ((module) => {
/***/ 833:
/***/ (function(module) {

@@ -1339,2 +1378,3 @@ "use strict";

module.exports = DebugPortAllocator;
function DebugPortAllocator() {

@@ -1345,3 +1385,3 @@ this.ports = Object.create(null);

DebugPortAllocator.prototype.nextAvailableStartingAt = function(starting) {
DebugPortAllocator.prototype.nextAvailableStartingAt = function (starting) {
while (this.ports[starting] === true) {

@@ -1352,3 +1392,3 @@ starting++;

if (starting >= MAX_PORTS) {
throw new Error('WorkerPool debug port limit reached: ' + starting + '>= ' + MAX_PORTS );
throw new Error('WorkerPool debug port limit reached: ' + starting + '>= ' + MAX_PORTS);
}

@@ -1361,3 +1401,3 @@

DebugPortAllocator.prototype.releasePort = function(port) {
DebugPortAllocator.prototype.releasePort = function (port) {
delete this.ports[port];

@@ -1367,51 +1407,36 @@ this.length--;

/***/ }),
/***/ 828:
/***/ (function(module, __unused_webpack_exports, __webpack_require__) {
/***/ }),
var requireFoolWebpack = __webpack_require__(397); // source: https://github.com/flexdinesh/browser-or-node
/***/ 735:
/***/ ((module, __unused_webpack_exports, __webpack_require__) => {
var requireFoolWebpack = __webpack_require__(981);
var isNode = function isNode(nodeProcess) {
return typeof nodeProcess !== 'undefined' && nodeProcess.versions != null && nodeProcess.versions.node != null;
};
// source: https://github.com/flexdinesh/browser-or-node
var isNode = function (nodeProcess) {
return (
typeof nodeProcess !== 'undefined' &&
nodeProcess.versions != null &&
nodeProcess.versions.node != null
);
}
module.exports.isNode = isNode
module.exports.isNode = isNode; // determines the JavaScript platform: browser or node
// determines the JavaScript platform: browser or node
module.exports.platform = typeof process !== 'undefined' && isNode(process)
? 'node'
: 'browser';
module.exports.platform = typeof process !== 'undefined' && isNode(process) ? 'node' : 'browser'; // determines whether the code is running in main thread or not
// note that in node.js we have to check both worker_thread and child_process
// determines whether the code is running in main thread or not
// note that in node.js we have to check both worker_thread and child_process
var worker_threads = tryRequireFoolWebpack('worker_threads');
module.exports.isMainThread = module.exports.platform === 'node'
? ((!worker_threads || worker_threads.isMainThread) && !process.connected)
: typeof Window !== 'undefined';
module.exports.isMainThread = module.exports.platform === 'node' ? (!worker_threads || worker_threads.isMainThread) && !process.connected : typeof Window !== 'undefined'; // determines the number of cpus available
// determines the number of cpus available
module.exports.cpus = module.exports.platform === 'browser'
? self.navigator.hardwareConcurrency
: requireFoolWebpack('os').cpus().length;
module.exports.cpus = module.exports.platform === 'browser' ? self.navigator.hardwareConcurrency : requireFoolWebpack('os').cpus().length;
function tryRequireFoolWebpack (module) {
function tryRequireFoolWebpack(module) {
try {
return requireFoolWebpack(module);
} catch(err) {
return null
} catch (err) {
return null;
}
}
/***/ }),
/***/ 241:
/***/ ((module) => {
/***/ 670:
/***/ (function(module) {

@@ -1423,12 +1448,10 @@ /**

*/
module.exports = "(()=>{var __webpack_modules__={736:(__unused_webpack_module,exports)=>{var __webpack_unused_export__,requireFoolWebpack=eval(\"typeof require !== 'undefined' ? require : function (module) { throw new Error('Module \\\" + module + \\\" not found.') }\"),TERMINATE_METHOD_ID=\"__workerpool-terminate__\",worker={exit:function(){}},WorkerThreads,parentPort;if(\"undefined\"!=typeof self&&\"function\"==typeof postMessage&&\"function\"==typeof addEventListener)worker.on=function(e,r){addEventListener(e,function(e){r(e.data)})},worker.send=function(e){postMessage(e)};else{if(\"undefined\"==typeof process)throw new Error(\"Script must be executed as a worker\");try{WorkerThreads=requireFoolWebpack(\"worker_threads\")}catch(error){if(\"object\"!=typeof error||null===error||\"MODULE_NOT_FOUND\"!==error.code)throw error}WorkerThreads&&null!==WorkerThreads.parentPort?(parentPort=WorkerThreads.parentPort,worker.send=parentPort.postMessage.bind(parentPort),worker.on=parentPort.on.bind(parentPort)):(worker.on=process.on.bind(process),worker.send=process.send.bind(process),worker.on(\"disconnect\",function(){process.exit(1)}),worker.exit=process.exit.bind(process))}function convertError(o){return Object.getOwnPropertyNames(o).reduce(function(e,r){return Object.defineProperty(e,r,{value:o[r],enumerable:!0})},{})}function isPromise(e){return e&&\"function\"==typeof e.then&&\"function\"==typeof e.catch}worker.methods={},worker.methods.run=function(e,r){e=new Function(\"return (\"+e+\").apply(null, arguments);\");return e.apply(e,r)},worker.methods.methods=function(){return Object.keys(worker.methods)},worker.on(\"message\",function(r){if(r===TERMINATE_METHOD_ID)return worker.exit(0);try{var e=worker.methods[r.method];if(!e)throw new Error('Unknown method \"'+r.method+'\"');e=e.apply(e,r.params);isPromise(e)?e.then(function(e){worker.send({id:r.id,result:e,error:null})}).catch(function(e){worker.send({id:r.id,result:null,error:convertError(e)})}):worker.send({id:r.id,result:e,error:null})}catch(e){worker.send({id:r.id,result:null,error:convertError(e)})}}),worker.register=function(e){if(e)for(var r in e)e.hasOwnProperty(r)&&(worker.methods[r]=e[r]);worker.send(\"ready\")},__webpack_unused_export__=worker.register}},__webpack_module_cache__={};function __webpack_require__(e){if(__webpack_module_cache__[e])return __webpack_module_cache__[e].exports;var r=__webpack_module_cache__[e]={exports:{}};return __webpack_modules__[e](r,r.exports,__webpack_require__),r.exports}__webpack_require__(736)})();";
module.exports = "!function(){var __webpack_modules__={744:function(__unused_webpack_module,exports){var __webpack_unused_export__;function _typeof(e){return(_typeof=\"function\"==typeof Symbol&&\"symbol\"==typeof Symbol.iterator?function(e){return typeof e}:function(e){return e&&\"function\"==typeof Symbol&&e.constructor===Symbol&&e!==Symbol.prototype?\"symbol\":typeof e})(e)}var requireFoolWebpack=eval(\"typeof require !== 'undefined' ? require : function (module) { throw new Error('Module \\\" + module + \\\" not found.') }\"),TERMINATE_METHOD_ID=\"__workerpool-terminate__\",worker={exit:function(){}},WorkerThreads,parentPort;if(\"undefined\"!=typeof self&&\"function\"==typeof postMessage&&\"function\"==typeof addEventListener)worker.on=function(e,r){addEventListener(e,function(e){r(e.data)})},worker.send=function(e){postMessage(e)};else{if(\"undefined\"==typeof process)throw new Error(\"Script must be executed as a worker\");try{WorkerThreads=requireFoolWebpack(\"worker_threads\")}catch(error){if(\"object\"!==_typeof(error)||null===error||\"MODULE_NOT_FOUND\"!==error.code)throw error}WorkerThreads&&null!==WorkerThreads.parentPort?(parentPort=WorkerThreads.parentPort,worker.send=parentPort.postMessage.bind(parentPort),worker.on=parentPort.on.bind(parentPort)):(worker.on=process.on.bind(process),worker.send=process.send.bind(process),worker.on(\"disconnect\",function(){process.exit(1)}),worker.exit=process.exit.bind(process))}function convertError(o){return Object.getOwnPropertyNames(o).reduce(function(e,r){return Object.defineProperty(e,r,{value:o[r],enumerable:!0})},{})}function isPromise(e){return e&&\"function\"==typeof e.then&&\"function\"==typeof e.catch}worker.methods={},worker.methods.run=function(e,r){e=new Function(\"return (\"+e+\").apply(null, arguments);\");return e.apply(e,r)},worker.methods.methods=function(){return Object.keys(worker.methods)};var currentRequestId=null;worker.on(\"message\",function(r){if(r===TERMINATE_METHOD_ID)return worker.exit(0);try{var e=worker.methods[r.method];if(!e)throw new Error('Unknown method \"'+r.method+'\"');currentRequestId=r.id;e=e.apply(e,r.params);isPromise(e)?e.then(function(e){worker.send({id:r.id,result:e,error:null}),currentRequestId=null}).catch(function(e){worker.send({id:r.id,result:null,error:convertError(e)}),currentRequestId=null}):(worker.send({id:r.id,result:e,error:null}),currentRequestId=null)}catch(e){worker.send({id:r.id,result:null,error:convertError(e)})}}),worker.register=function(e){if(e)for(var r in e)e.hasOwnProperty(r)&&(worker.methods[r]=e[r]);worker.send(\"ready\")},worker.emit=function(e){currentRequestId&&worker.send({id:currentRequestId,isEvent:!0,payload:e})},__webpack_unused_export__=worker.register,__webpack_unused_export__=worker.emit}},__webpack_module_cache__={};function __webpack_require__(e){if(__webpack_module_cache__[e])return __webpack_module_cache__[e].exports;var r=__webpack_module_cache__[e]={exports:{}};return __webpack_modules__[e](r,r.exports,__webpack_require__),r.exports}__webpack_require__(744)}();";
/***/ }),
/***/ 138:
/***/ ((__unused_webpack_module, exports, __webpack_require__) => {
/***/ 352:
/***/ (function(__unused_webpack_module, exports, __webpack_require__) {
var environment = __webpack_require__(735);
var environment = __webpack_require__(828);
/**

@@ -1440,8 +1463,9 @@ * Create a new worker pool

*/
exports.pool = function pool(script, options) {
var Pool = __webpack_require__(542);
var Pool = __webpack_require__(345);
return new Pool(script, options);
};
/**

@@ -1451,7 +1475,20 @@ * Create a worker and optionally register a set of methods to the worker.

*/
exports.worker = function worker(methods) {
var worker = __webpack_require__(736);
var worker = __webpack_require__(744);
worker.add(methods);
};
/**
* Sends an event to the parent worker pool.
* @param {any} payload
*/
exports.workerEmit = function workerEmit(payload) {
var worker = __webpack_require__(744);
worker.emit(payload);
};
/**

@@ -1461,4 +1498,5 @@ * Create a promise.

*/
exports.Promise = __webpack_require__(514);
exports.Promise = __webpack_require__(219);
exports.platform = environment.platform;

@@ -1470,20 +1508,16 @@ exports.isMainThread = environment.isMainThread;

/***/ 981:
/***/ ((module) => {
/***/ 397:
/***/ (function(module) {
// source of inspiration: https://github.com/sindresorhus/require-fool-webpack
var requireFoolWebpack = eval(
'typeof require !== \'undefined\' ' +
'? require ' +
': function (module) { throw new Error(\'Module " + module + " not found.\') }'
);
var requireFoolWebpack = eval('typeof require !== \'undefined\' ' + '? require ' + ': function (module) { throw new Error(\'Module " + module + " not found.\') }');
module.exports = requireFoolWebpack;
/***/ }),
/***/ 736:
/***/ ((__unused_webpack_module, exports) => {
/***/ 744:
/***/ (function(__unused_webpack_module, exports) {
function _typeof(obj) { "@babel/helpers - typeof"; if (typeof Symbol === "function" && typeof Symbol.iterator === "symbol") { _typeof = function _typeof(obj) { return typeof obj; }; } else { _typeof = function _typeof(obj) { return obj && typeof Symbol === "function" && obj.constructor === Symbol && obj !== Symbol.prototype ? "symbol" : typeof obj; }; } return _typeof(obj); }
/**

@@ -1493,10 +1527,4 @@ * worker must be started as a child process or a web worker.

*/
// source of inspiration: https://github.com/sindresorhus/require-fool-webpack
var requireFoolWebpack = eval(
'typeof require !== \'undefined\'' +
' ? require' +
' : function (module) { throw new Error(\'Module " + module + " not found.\') }'
);
var requireFoolWebpack = eval('typeof require !== \'undefined\'' + ' ? require' + ' : function (module) { throw new Error(\'Module " + module + " not found.\') }');
/**

@@ -1506,11 +1534,11 @@ * Special message sent by parent which causes the worker to terminate itself.

*/
var TERMINATE_METHOD_ID = '__workerpool-terminate__';
// var nodeOSPlatform = require('./environment').nodeOSPlatform;
var TERMINATE_METHOD_ID = '__workerpool-terminate__'; // var nodeOSPlatform = require('./environment').nodeOSPlatform;
// create a worker API for sending and receiving messages which works both on
// node.js and in the browser
var worker = {
exit: function() {}
exit: function exit() {}
};
if (typeof self !== 'undefined' && typeof postMessage === 'function' && typeof addEventListener === 'function') {

@@ -1521,17 +1549,16 @@ // worker in the browser

callback(message.data);
})
});
};
worker.send = function (message) {
postMessage(message);
};
}
else if (typeof process !== 'undefined') {
} else if (typeof process !== 'undefined') {
// node.js
var WorkerThreads;
var WorkerThreads;
try {
WorkerThreads = requireFoolWebpack('worker_threads');
} catch(error) {
if (typeof error === 'object' && error !== null && error.code === 'MODULE_NOT_FOUND') {
// no worker_threads, fallback to sub-process based workers
} catch (error) {
if (_typeof(error) === 'object' && error !== null && error.code === 'MODULE_NOT_FOUND') {// no worker_threads, fallback to sub-process based workers
} else {

@@ -1543,5 +1570,5 @@ throw error;

if (WorkerThreads &&
/* if there is a parentPort, we are in a WorkerThread */
WorkerThreads.parentPort !== null) {
var parentPort = WorkerThreads.parentPort;
/* if there is a parentPort, we are in a WorkerThread */
WorkerThreads.parentPort !== null) {
var parentPort = WorkerThreads.parentPort;
worker.send = parentPort.postMessage.bind(parentPort);

@@ -1551,4 +1578,4 @@ worker.on = parentPort.on.bind(parentPort);

worker.on = process.on.bind(process);
worker.send = process.send.bind(process);
// register disconnect handler only for subprocess worker to exit when parent is killed unexpectedly
worker.send = process.send.bind(process); // register disconnect handler only for subprocess worker to exit when parent is killed unexpectedly
worker.on('disconnect', function () {

@@ -1559,4 +1586,3 @@ process.exit(1);

}
}
else {
} else {
throw new Error('Script must be executed as a worker');

@@ -1566,10 +1592,9 @@ }

function convertError(error) {
return Object.getOwnPropertyNames(error).reduce(function(product, name) {
return Object.getOwnPropertyNames(error).reduce(function (product, name) {
return Object.defineProperty(product, name, {
value: error[name],
enumerable: true
value: error[name],
enumerable: true
});
}, {});
}
/**

@@ -1581,9 +1606,10 @@ * Test whether a value is a Promise via duck typing.

*/
function isPromise(value) {
return value && (typeof value.then === 'function') && (typeof value.catch === 'function');
}
return value && typeof value.then === 'function' && typeof value["catch"] === 'function';
} // functions available externally
// functions available externally
worker.methods = {};
/**

@@ -1595,2 +1621,3 @@ * Execute a function with provided arguments

*/
worker.methods.run = function run(fn, args) {

@@ -1600,3 +1627,2 @@ var f = new Function('return (' + fn + ').apply(null, arguments);');

};
/**

@@ -1606,2 +1632,4 @@ * Get a list with methods available on this worker

*/
worker.methods.methods = function methods() {

@@ -1611,2 +1639,3 @@ return Object.keys(worker.methods);

var currentRequestId = null;
worker.on('message', function (request) {

@@ -1616,2 +1645,3 @@ if (request === TERMINATE_METHOD_ID) {

}
try {

@@ -1621,3 +1651,4 @@ var method = worker.methods[request.method];

if (method) {
// execute the function
currentRequestId = request.id; // execute the function
var result = method.apply(method, request.params);

@@ -1627,19 +1658,18 @@

// promise returned, resolve this and then return
result
.then(function (result) {
worker.send({
id: request.id,
result: result,
error: null
});
})
.catch(function (err) {
worker.send({
id: request.id,
result: null,
error: convertError(err)
});
});
}
else {
result.then(function (result) {
worker.send({
id: request.id,
result: result,
error: null
});
currentRequestId = null;
})["catch"](function (err) {
worker.send({
id: request.id,
result: null,
error: convertError(err)
});
currentRequestId = null;
});
} else {
// immediate result

@@ -1651,9 +1681,8 @@ worker.send({

});
currentRequestId = null;
}
}
else {
} else {
throw new Error('Unknown method "' + request.method + '"');
}
}
catch (err) {
} catch (err) {
worker.send({

@@ -1666,3 +1695,2 @@ id: request.id,

});
/**

@@ -1672,4 +1700,4 @@ * Register methods to the worker

*/
worker.register = function (methods) {
if (methods) {

@@ -1684,3 +1712,12 @@ for (var name in methods) {

worker.send('ready');
};
worker.emit = function (payload) {
if (currentRequestId) {
worker.send({
id: currentRequestId,
isEvent: true,
payload: payload
});
}
};

@@ -1690,5 +1727,5 @@

exports.add = worker.register;
exports.emit = worker.emit;
}
/***/ })

@@ -1725,3 +1762,3 @@

/******/ // Load entry module and return exports
/******/ return __webpack_require__(138);
/******/ return __webpack_require__(352);
/******/ })()

@@ -1728,0 +1765,0 @@ ;

2

dist/workerpool.min.js
/*! For license information please see workerpool.min.js.LICENSE.txt */
!function(e,r){"object"==typeof exports&&"object"==typeof module?module.exports=r():"function"==typeof define&&define.amd?define("workerpool",[],r):"object"==typeof exports?exports.workerpool=r():e.workerpool=r()}("undefined"!=typeof self?self:this,(function(){return(()=>{var __webpack_modules__={542:(e,r,t)=>{var o=t(514),n=t(547),i=t(735),s=new(t(530));function u(e,r){"string"==typeof e?this.script=e||null:(this.script=null,r=e),this.workers=[],this.tasks=[],r=r||{},this.forkArgs=r.forkArgs||[],this.forkOpts=r.forkOpts||{},this.debugPortStart=r.debugPortStart||43210,this.nodeWorker=r.nodeWorker,this.workerType=r.workerType||r.nodeWorker||"auto",this.maxQueueSize=r.maxQueueSize||1/0,r&&"maxWorkers"in r?(function(e){if(!c(e)||!a(e)||e<1)throw new TypeError("Option maxWorkers must be an integer number >= 1")}(r.maxWorkers),this.maxWorkers=r.maxWorkers):this.maxWorkers=Math.max((i.cpus||4)-1,1),r&&"minWorkers"in r&&("max"===r.minWorkers?this.minWorkers=this.maxWorkers:(function(e){if(!c(e)||!a(e)||e<0)throw new TypeError("Option minWorkers must be an integer number >= 0")}(r.minWorkers),this.minWorkers=r.minWorkers,this.maxWorkers=Math.max(this.minWorkers,this.maxWorkers)),this._ensureMinWorkers()),this._boundNext=this._next.bind(this),"thread"===this.workerType&&n.ensureWorkerThreads()}function c(e){return"number"==typeof e}function a(e){return Math.round(e)==e}u.prototype.exec=function(e,r){if(r&&!Array.isArray(r))throw new TypeError('Array expected as argument "params"');if("string"==typeof e){var t=o.defer();if(this.tasks.length>=this.maxQueueSize)throw new Error("Max queue size of "+this.maxQueueSize+" reached");var n=this.tasks,i={method:e,params:r,resolver:t,timeout:null};n.push(i);var s=t.promise.timeout;return t.promise.timeout=function(e){return-1!==n.indexOf(i)?(i.timeout=e,t.promise):s.call(t.promise,e)},this._next(),t.promise}if("function"==typeof e)return this.exec("run",[String(e),r]);throw new TypeError('Function or string expected as argument "method"')},u.prototype.proxy=function(){if(arguments.length>0)throw new Error("No arguments expected");var e=this;return this.exec("methods").then((function(r){var t={};return r.forEach((function(r){t[r]=function(){return e.exec(r,Array.prototype.slice.call(arguments))}})),t}))},u.prototype._next=function(){if(this.tasks.length>0){var e=this._getWorker();if(e){var r=this,t=this.tasks.shift();if(t.resolver.promise.pending){var o=e.exec(t.method,t.params,t.resolver).then(r._boundNext).catch((function(){if(e.terminated)return r._removeWorker(e)})).then((function(){r._next()}));"number"==typeof t.timeout&&o.timeout(t.timeout)}else r._next()}}},u.prototype._getWorker=function(){for(var e=this.workers,r=0;r<e.length;r++){var t=e[r];if(!1===t.busy())return t}return e.length<this.maxWorkers?(t=this._createWorkerHandler(),e.push(t),t):null},u.prototype._removeWorker=function(e){return s.releasePort(e.debugPort),this._removeWorkerFromList(e),this._ensureMinWorkers(),new o((function(r,t){e.terminate(!1,(function(o){o?t(o):r(e)}))}))},u.prototype._removeWorkerFromList=function(e){var r=this.workers.indexOf(e);-1!==r&&this.workers.splice(r,1)},u.prototype.terminate=function(e,r){this.tasks.forEach((function(e){e.resolver.reject(new Error("Pool terminated"))})),this.tasks.length=0;var t=function(e){this._removeWorkerFromList(e)}.bind(this),n=[];return this.workers.slice().forEach((function(o){var i=o.terminateAndNotify(e,r).then(t);n.push(i)})),o.all(n)},u.prototype.stats=function(){var e=this.workers.length,r=this.workers.filter((function(e){return e.busy()})).length;return{totalWorkers:e,busyWorkers:r,idleWorkers:e-r,pendingTasks:this.tasks.length,activeTasks:r}},u.prototype._ensureMinWorkers=function(){if(this.minWorkers)for(var e=this.workers.length;e<this.minWorkers;e++)this.workers.push(this._createWorkerHandler())},u.prototype._createWorkerHandler=function(){return new n(this.script,{forkArgs:this.forkArgs,forkOpts:this.forkOpts,debugPort:s.nextAvailableStartingAt(this.debugPortStart),workerType:this.workerType})},e.exports=u},514:e=>{"use strict";function r(e,i){var s=this;if(!(this instanceof r))throw new SyntaxError("Constructor must be called with the new operator");if("function"!=typeof e)throw new SyntaxError("Function parameter handler(resolve, reject) missing");var u=[],c=[];this.resolved=!1,this.rejected=!1,this.pending=!0;var a=function(e,r){u.push(e),c.push(r)};this.then=function(e,o){return new r((function(r,n){var i=e?t(e,r,n):r,s=o?t(o,r,n):n;a(i,s)}),s)};var p=function(e){return s.resolved=!0,s.rejected=!1,s.pending=!1,u.forEach((function(r){r(e)})),a=function(r,t){r(e)},p=f=function(){},s},f=function(e){return s.resolved=!1,s.rejected=!0,s.pending=!1,c.forEach((function(r){r(e)})),a=function(r,t){t(e)},p=f=function(){},s};this.cancel=function(){return i?i.cancel():f(new o),s},this.timeout=function(e){if(i)i.timeout(e);else{var r=setTimeout((function(){f(new n("Promise timed out after "+e+" ms"))}),e);s.always((function(){clearTimeout(r)}))}return s},e((function(e){p(e)}),(function(e){f(e)}))}function t(e,r,t){return function(o){try{var n=e(o);n&&"function"==typeof n.then&&"function"==typeof n.catch?n.then(r,t):r(n)}catch(e){t(e)}}}function o(e){this.message=e||"promise cancelled",this.stack=(new Error).stack}function n(e){this.message=e||"timeout exceeded",this.stack=(new Error).stack}r.prototype.catch=function(e){return this.then(null,e)},r.prototype.always=function(e){return this.then(e,e)},r.all=function(e){return new r((function(r,t){var o=e.length,n=[];o?e.forEach((function(e,i){e.then((function(e){n[i]=e,0==--o&&r(n)}),(function(e){o=0,t(e)}))})):r(n)}))},r.defer=function(){var e={};return e.promise=new r((function(r,t){e.resolve=r,e.reject=t})),e},o.prototype=new Error,o.prototype.constructor=Error,o.prototype.name="CancellationError",r.CancellationError=o,n.prototype=new Error,n.prototype.constructor=Error,n.prototype.name="TimeoutError",r.TimeoutError=n,e.exports=r},547:(e,r,t)=>{"use strict";var o=t(514),n=t(735),i=t(981),s="__workerpool-terminate__";function u(){var e=a();if(!e)throw new Error("WorkerPool: workerType = 'thread' is not supported, Node >= 11.7.0 required");return e}function c(){if("function"!=typeof Worker&&("object"!=typeof Worker||"function"!=typeof Worker.prototype.constructor))throw new Error("WorkerPool: Web Workers not supported")}function a(){try{return i("worker_threads")}catch(e){if("object"==typeof e&&null!==e&&"MODULE_NOT_FOUND"===e.code)return null;throw e}}function p(e,r){var t=new r(e);return t.isBrowserWorker=!0,t.on=function(e,r){this.addEventListener(e,(function(e){r(e.data)}))},t.send=function(e){this.postMessage(e)},t}function f(e,r){var t=new r.Worker(e,{stdout:!1,stderr:!1});return t.isWorkerThread=!0,t.send=function(e){this.postMessage(e)},t.kill=function(){return this.terminate(),!0},t.disconnect=function(){this.terminate()},t}function d(e,r,t){var o=t.fork(e,r.forkArgs,r.forkOpts);return o.isChildProcess=!0,o}function h(e){e=e||{};var r=process.execArgv.join(" "),t=-1!==r.indexOf("--inspect"),o=-1!==r.indexOf("--debug-brk"),n=[];return t&&(n.push("--inspect="+e.debugPort),o&&n.push("--debug-brk")),process.execArgv.forEach((function(e){e.indexOf("--max-old-space-size")>-1&&n.push(e)})),Object.assign({},e,{forkArgs:e.forkArgs,forkOpts:Object.assign({},e.forkOpts,{execArgv:(e.forkOpts&&e.forkOpts.execArgv||[]).concat(n)})})}function l(e,r){var o=this,s=r||{};function l(e){for(var r in o.terminated=!0,o.processing)void 0!==o.processing[r]&&o.processing[r].resolver.reject(e);o.processing=Object.create(null)}this.script=e||function(){if("browser"===n.platform){if("undefined"==typeof Blob)throw new Error("Blob not supported by the browser");if(!window.URL||"function"!=typeof window.URL.createObjectURL)throw new Error("URL.createObjectURL not supported by the browser");var e=new Blob([t(241)],{type:"text/javascript"});return window.URL.createObjectURL(e)}return __dirname+"/worker.js"}(),this.worker=function(e,r){if("web"===r.workerType)return c(),p(e,Worker);if("thread"===r.workerType)return f(e,t=u());if("process"!==r.workerType&&r.workerType){if("browser"===n.platform)return c(),p(e,Worker);var t=a();return t?f(e,t):d(e,h(r),i("child_process"))}return d(e,h(r),i("child_process"))}(this.script,s),this.debugPort=s.debugPort,e||(this.worker.ready=!0),this.requestQueue=[],this.worker.on("message",(function(e){if("string"==typeof e&&"ready"===e)o.worker.ready=!0,o.requestQueue.forEach(o.worker.send.bind(o.worker)),o.requestQueue=[];else{var r=e.id,t=o.processing[r];void 0!==t&&(delete o.processing[r],!0===o.terminating&&o.terminate(),e.error?t.resolver.reject(function(e){for(var r=new Error(""),t=Object.keys(e),o=0;o<t.length;o++)r[t[o]]=e[t[o]];return r}(e.error)):t.resolver.resolve(e.result))}}));var k=this.worker;this.worker.on("error",l),this.worker.on("exit",(function(e,r){var t="Workerpool Worker terminated Unexpectedly\n";t+=" exitCode: `"+e+"`\n",t+=" signalCode: `"+r+"`\n",t+=" workerpool.script: `"+o.script+"`\n",t+=" spawnArgs: `"+k.spawnargs+"`\n",t+=" spawnfile: `"+k.spawnfile+"`\n",t+=" stdout: `"+k.stdout+"`\n",t+=" stderr: `"+k.stderr+"`\n",l(new Error(t))})),this.processing=Object.create(null),this.terminating=!1,this.terminated=!1,this.terminationHandler=null,this.lastId=0}l.prototype.methods=function(){return this.exec("methods")},l.prototype.exec=function(e,r,t){t||(t=o.defer());var n=++this.lastId;this.processing[n]={id:n,resolver:t};var i={id:n,method:e,params:r};this.terminated?t.reject(new Error("Worker is terminated")):this.worker.ready?this.worker.send(i):this.requestQueue.push(i);var s=this;return t.promise.catch((function(e){if(e instanceof o.CancellationError||e instanceof o.TimeoutError)return delete s.processing[n],s.terminateAndNotify(!0).then((function(){throw e}),(function(e){throw e}));throw e}))},l.prototype.busy=function(){return Object.keys(this.processing).length>0},l.prototype.terminate=function(e,r){var t=this;if(e){for(var o in this.processing)void 0!==this.processing[o]&&this.processing[o].resolver.reject(new Error("Worker terminated"));this.processing=Object.create(null)}if("function"==typeof r&&(this.terminationHandler=r),this.busy())this.terminating=!0;else{var n=function(e){if(t.terminated=!0,t.worker=null,t.terminating=!1,t.terminationHandler)t.terminationHandler(e,t);else if(e)throw e};if(this.worker){if("function"==typeof this.worker.kill){if(this.worker.killed)return void n(new Error("worker already killed!"));if(this.worker.isChildProcess){var i=setTimeout((function(){t.worker.kill()}),1e3);this.worker.once("exit",(function(){clearTimeout(i),t.worker.killed=!0,n()})),this.worker.ready?this.worker.send(s):this.worker.requestQueue.push(s)}else this.worker.kill(),this.worker.killed=!0,n();return}if("function"!=typeof this.worker.terminate)throw new Error("Failed to terminate worker");this.worker.terminate(),this.worker.killed=!0}n()}},l.prototype.terminateAndNotify=function(e,r){var t=o.defer();return r&&(t.promise.timeout=r),this.terminate(e,(function(e,r){e?t.reject(e):t.resolve(r)})),t.promise},e.exports=l,e.exports._tryRequireWorkerThreads=a,e.exports._setupProcessWorker=d,e.exports._setupBrowserWorker=p,e.exports._setupWorkerThreadWorker=f,e.exports.ensureWorkerThreads=u},530:e=>{"use strict";function r(){this.ports=Object.create(null),this.length=0}e.exports=r,r.prototype.nextAvailableStartingAt=function(e){for(;!0===this.ports[e];)e++;if(e>=65535)throw new Error("WorkerPool debug port limit reached: "+e+">= 65535");return this.ports[e]=!0,this.length++,e},r.prototype.releasePort=function(e){delete this.ports[e],this.length--}},735:(e,r,t)=>{var o=t(981),n=function(e){return void 0!==e&&null!=e.versions&&null!=e.versions.node};e.exports.isNode=n,e.exports.platform="undefined"!=typeof process&&n(process)?"node":"browser";var i=function(e){try{return o("worker_threads")}catch(e){return null}}();e.exports.isMainThread="node"===e.exports.platform?(!i||i.isMainThread)&&!process.connected:"undefined"!=typeof Window,e.exports.cpus="browser"===e.exports.platform?self.navigator.hardwareConcurrency:o("os").cpus().length},241:e=>{e.exports='(()=>{var __webpack_modules__={736:(__unused_webpack_module,exports)=>{var __webpack_unused_export__,requireFoolWebpack=eval("typeof require !== \'undefined\' ? require : function (module) { throw new Error(\'Module \\" + module + \\" not found.\') }"),TERMINATE_METHOD_ID="__workerpool-terminate__",worker={exit:function(){}},WorkerThreads,parentPort;if("undefined"!=typeof self&&"function"==typeof postMessage&&"function"==typeof addEventListener)worker.on=function(e,r){addEventListener(e,function(e){r(e.data)})},worker.send=function(e){postMessage(e)};else{if("undefined"==typeof process)throw new Error("Script must be executed as a worker");try{WorkerThreads=requireFoolWebpack("worker_threads")}catch(error){if("object"!=typeof error||null===error||"MODULE_NOT_FOUND"!==error.code)throw error}WorkerThreads&&null!==WorkerThreads.parentPort?(parentPort=WorkerThreads.parentPort,worker.send=parentPort.postMessage.bind(parentPort),worker.on=parentPort.on.bind(parentPort)):(worker.on=process.on.bind(process),worker.send=process.send.bind(process),worker.on("disconnect",function(){process.exit(1)}),worker.exit=process.exit.bind(process))}function convertError(o){return Object.getOwnPropertyNames(o).reduce(function(e,r){return Object.defineProperty(e,r,{value:o[r],enumerable:!0})},{})}function isPromise(e){return e&&"function"==typeof e.then&&"function"==typeof e.catch}worker.methods={},worker.methods.run=function(e,r){e=new Function("return ("+e+").apply(null, arguments);");return e.apply(e,r)},worker.methods.methods=function(){return Object.keys(worker.methods)},worker.on("message",function(r){if(r===TERMINATE_METHOD_ID)return worker.exit(0);try{var e=worker.methods[r.method];if(!e)throw new Error(\'Unknown method "\'+r.method+\'"\');e=e.apply(e,r.params);isPromise(e)?e.then(function(e){worker.send({id:r.id,result:e,error:null})}).catch(function(e){worker.send({id:r.id,result:null,error:convertError(e)})}):worker.send({id:r.id,result:e,error:null})}catch(e){worker.send({id:r.id,result:null,error:convertError(e)})}}),worker.register=function(e){if(e)for(var r in e)e.hasOwnProperty(r)&&(worker.methods[r]=e[r]);worker.send("ready")},__webpack_unused_export__=worker.register}},__webpack_module_cache__={};function __webpack_require__(e){if(__webpack_module_cache__[e])return __webpack_module_cache__[e].exports;var r=__webpack_module_cache__[e]={exports:{}};return __webpack_modules__[e](r,r.exports,__webpack_require__),r.exports}__webpack_require__(736)})();'},138:(e,r,t)=>{var o=t(735);r.pool=function(e,r){return new(t(542))(e,r)},r.worker=function(e){t(736).add(e)},r.Promise=t(514),r.platform=o.platform,r.isMainThread=o.isMainThread,r.cpus=o.cpus},981:module=>{var requireFoolWebpack=eval("typeof require !== 'undefined' ? require : function (module) { throw new Error('Module \" + module + \" not found.') }");module.exports=requireFoolWebpack},736:(__unused_webpack_module,exports)=>{var requireFoolWebpack=eval("typeof require !== 'undefined' ? require : function (module) { throw new Error('Module \" + module + \" not found.') }"),TERMINATE_METHOD_ID="__workerpool-terminate__",worker={exit:function(){}};if("undefined"!=typeof self&&"function"==typeof postMessage&&"function"==typeof addEventListener)worker.on=function(e,r){addEventListener(e,(function(e){r(e.data)}))},worker.send=function(e){postMessage(e)};else{if("undefined"==typeof process)throw new Error("Script must be executed as a worker");var WorkerThreads;try{WorkerThreads=requireFoolWebpack("worker_threads")}catch(e){if("object"!=typeof e||null===e||"MODULE_NOT_FOUND"!==e.code)throw e}if(WorkerThreads&&null!==WorkerThreads.parentPort){var parentPort=WorkerThreads.parentPort;worker.send=parentPort.postMessage.bind(parentPort),worker.on=parentPort.on.bind(parentPort)}else worker.on=process.on.bind(process),worker.send=process.send.bind(process),worker.on("disconnect",(function(){process.exit(1)})),worker.exit=process.exit.bind(process)}function convertError(e){return Object.getOwnPropertyNames(e).reduce((function(r,t){return Object.defineProperty(r,t,{value:e[t],enumerable:!0})}),{})}function isPromise(e){return e&&"function"==typeof e.then&&"function"==typeof e.catch}worker.methods={},worker.methods.run=function(e,r){var t=new Function("return ("+e+").apply(null, arguments);");return t.apply(t,r)},worker.methods.methods=function(){return Object.keys(worker.methods)},worker.on("message",(function(e){if(e===TERMINATE_METHOD_ID)return worker.exit(0);try{var r=worker.methods[e.method];if(!r)throw new Error('Unknown method "'+e.method+'"');var t=r.apply(r,e.params);isPromise(t)?t.then((function(r){worker.send({id:e.id,result:r,error:null})})).catch((function(r){worker.send({id:e.id,result:null,error:convertError(r)})})):worker.send({id:e.id,result:t,error:null})}catch(r){worker.send({id:e.id,result:null,error:convertError(r)})}})),worker.register=function(e){if(e)for(var r in e)e.hasOwnProperty(r)&&(worker.methods[r]=e[r]);worker.send("ready")},exports.add=worker.register}},__webpack_module_cache__={};function __webpack_require__(e){if(__webpack_module_cache__[e])return __webpack_module_cache__[e].exports;var r=__webpack_module_cache__[e]={exports:{}};return __webpack_modules__[e](r,r.exports,__webpack_require__),r.exports}return __webpack_require__(138)})()}));
!function(e,r){"object"==typeof exports&&"object"==typeof module?module.exports=r():"function"==typeof define&&define.amd?define("workerpool",[],r):"object"==typeof exports?exports.workerpool=r():e.workerpool=r()}("undefined"!=typeof self?self:this,(function(){return function(){var __webpack_modules__={345:function(e,r,t){var o=t(219),n=t(751),i=t(828),s=new(t(833));function u(e,r){"string"==typeof e?this.script=e||null:(this.script=null,r=e),this.workers=[],this.tasks=[],r=r||{},this.forkArgs=r.forkArgs||[],this.forkOpts=r.forkOpts||{},this.debugPortStart=r.debugPortStart||43210,this.nodeWorker=r.nodeWorker,this.workerType=r.workerType||r.nodeWorker||"auto",this.maxQueueSize=r.maxQueueSize||1/0,r&&"maxWorkers"in r?(function(e){if(!c(e)||!a(e)||e<1)throw new TypeError("Option maxWorkers must be an integer number >= 1")}(r.maxWorkers),this.maxWorkers=r.maxWorkers):this.maxWorkers=Math.max((i.cpus||4)-1,1),r&&"minWorkers"in r&&("max"===r.minWorkers?this.minWorkers=this.maxWorkers:(function(e){if(!c(e)||!a(e)||e<0)throw new TypeError("Option minWorkers must be an integer number >= 0")}(r.minWorkers),this.minWorkers=r.minWorkers,this.maxWorkers=Math.max(this.minWorkers,this.maxWorkers)),this._ensureMinWorkers()),this._boundNext=this._next.bind(this),"thread"===this.workerType&&n.ensureWorkerThreads()}function c(e){return"number"==typeof e}function a(e){return Math.round(e)==e}u.prototype.exec=function(e,r,t){if(r&&!Array.isArray(r))throw new TypeError('Array expected as argument "params"');if("string"==typeof e){var n=o.defer();if(this.tasks.length>=this.maxQueueSize)throw new Error("Max queue size of "+this.maxQueueSize+" reached");var i=this.tasks,s={method:e,params:r,resolver:n,timeout:null,options:t};i.push(s);var u=n.promise.timeout;return n.promise.timeout=function(e){return-1!==i.indexOf(s)?(s.timeout=e,n.promise):u.call(n.promise,e)},this._next(),n.promise}if("function"==typeof e)return this.exec("run",[String(e),r]);throw new TypeError('Function or string expected as argument "method"')},u.prototype.proxy=function(){if(arguments.length>0)throw new Error("No arguments expected");var e=this;return this.exec("methods").then((function(r){var t={};return r.forEach((function(r){t[r]=function(){return e.exec(r,Array.prototype.slice.call(arguments))}})),t}))},u.prototype._next=function(){if(this.tasks.length>0){var e=this._getWorker();if(e){var r=this,t=this.tasks.shift();if(t.resolver.promise.pending){var o=e.exec(t.method,t.params,t.resolver,t.options).then(r._boundNext).catch((function(){if(e.terminated)return r._removeWorker(e)})).then((function(){r._next()}));"number"==typeof t.timeout&&o.timeout(t.timeout)}else r._next()}}},u.prototype._getWorker=function(){for(var e=this.workers,r=0;r<e.length;r++){var t=e[r];if(!1===t.busy())return t}return e.length<this.maxWorkers?(t=this._createWorkerHandler(),e.push(t),t):null},u.prototype._removeWorker=function(e){return s.releasePort(e.debugPort),this._removeWorkerFromList(e),this._ensureMinWorkers(),new o((function(r,t){e.terminate(!1,(function(o){o?t(o):r(e)}))}))},u.prototype._removeWorkerFromList=function(e){var r=this.workers.indexOf(e);-1!==r&&this.workers.splice(r,1)},u.prototype.terminate=function(e,r){this.tasks.forEach((function(e){e.resolver.reject(new Error("Pool terminated"))})),this.tasks.length=0;var t=function(e){this._removeWorkerFromList(e)}.bind(this),n=[];return this.workers.slice().forEach((function(o){var i=o.terminateAndNotify(e,r).then(t);n.push(i)})),o.all(n)},u.prototype.stats=function(){var e=this.workers.length,r=this.workers.filter((function(e){return e.busy()})).length;return{totalWorkers:e,busyWorkers:r,idleWorkers:e-r,pendingTasks:this.tasks.length,activeTasks:r}},u.prototype._ensureMinWorkers=function(){if(this.minWorkers)for(var e=this.workers.length;e<this.minWorkers;e++)this.workers.push(this._createWorkerHandler())},u.prototype._createWorkerHandler=function(){return new n(this.script,{forkArgs:this.forkArgs,forkOpts:this.forkOpts,debugPort:s.nextAvailableStartingAt(this.debugPortStart),workerType:this.workerType})},e.exports=u},219:function(e){"use strict";function r(e,i){var s=this;if(!(this instanceof r))throw new SyntaxError("Constructor must be called with the new operator");if("function"!=typeof e)throw new SyntaxError("Function parameter handler(resolve, reject) missing");var u=[],c=[];this.resolved=!1,this.rejected=!1,this.pending=!0;var a=function(e,r){u.push(e),c.push(r)};this.then=function(e,o){return new r((function(r,n){var i=e?t(e,r,n):r,s=o?t(o,r,n):n;a(i,s)}),s)};var f=function(e){return s.resolved=!0,s.rejected=!1,s.pending=!1,u.forEach((function(r){r(e)})),a=function(r,t){r(e)},f=p=function(){},s},p=function(e){return s.resolved=!1,s.rejected=!0,s.pending=!1,c.forEach((function(r){r(e)})),a=function(r,t){t(e)},f=p=function(){},s};this.cancel=function(){return i?i.cancel():p(new o),s},this.timeout=function(e){if(i)i.timeout(e);else{var r=setTimeout((function(){p(new n("Promise timed out after "+e+" ms"))}),e);s.always((function(){clearTimeout(r)}))}return s},e((function(e){f(e)}),(function(e){p(e)}))}function t(e,r,t){return function(o){try{var n=e(o);n&&"function"==typeof n.then&&"function"==typeof n.catch?n.then(r,t):r(n)}catch(e){t(e)}}}function o(e){this.message=e||"promise cancelled",this.stack=(new Error).stack}function n(e){this.message=e||"timeout exceeded",this.stack=(new Error).stack}r.prototype.catch=function(e){return this.then(null,e)},r.prototype.always=function(e){return this.then(e,e)},r.all=function(e){return new r((function(r,t){var o=e.length,n=[];o?e.forEach((function(e,i){e.then((function(e){n[i]=e,0==--o&&r(n)}),(function(e){o=0,t(e)}))})):r(n)}))},r.defer=function(){var e={};return e.promise=new r((function(r,t){e.resolve=r,e.reject=t})),e},o.prototype=new Error,o.prototype.constructor=Error,o.prototype.name="CancellationError",r.CancellationError=o,n.prototype=new Error,n.prototype.constructor=Error,n.prototype.name="TimeoutError",r.TimeoutError=n,e.exports=r},751:function(e,r,t){"use strict";function o(e,r){(null==r||r>e.length)&&(r=e.length);for(var t=0,o=new Array(r);t<r;t++)o[t]=e[t];return o}function n(e){return(n="function"==typeof Symbol&&"symbol"==typeof Symbol.iterator?function(e){return typeof e}:function(e){return e&&"function"==typeof Symbol&&e.constructor===Symbol&&e!==Symbol.prototype?"symbol":typeof e})(e)}var i=t(219),s=t(828),u=t(397),c="__workerpool-terminate__";function a(){var e=p();if(!e)throw new Error("WorkerPool: workerType = 'thread' is not supported, Node >= 11.7.0 required");return e}function f(){if("function"!=typeof Worker&&("object"!==("undefined"==typeof Worker?"undefined":n(Worker))||"function"!=typeof Worker.prototype.constructor))throw new Error("WorkerPool: Web Workers not supported")}function p(){try{return u("worker_threads")}catch(e){if("object"===n(e)&&null!==e&&"MODULE_NOT_FOUND"===e.code)return null;throw e}}function d(e,r){var t=new r(e);return t.isBrowserWorker=!0,t.on=function(e,r){this.addEventListener(e,(function(e){r(e.data)}))},t.send=function(e){this.postMessage(e)},t}function l(e,r){var t=new r.Worker(e,{stdout:!1,stderr:!1});return t.isWorkerThread=!0,t.send=function(e){this.postMessage(e)},t.kill=function(){return this.terminate(),!0},t.disconnect=function(){this.terminate()},t}function h(e,r,t){var o=t.fork(e,r.forkArgs,r.forkOpts);return o.isChildProcess=!0,o}function k(e){e=e||{};var r=process.execArgv.join(" "),t=-1!==r.indexOf("--inspect"),o=-1!==r.indexOf("--debug-brk"),n=[];return t&&(n.push("--inspect="+e.debugPort),o&&n.push("--debug-brk")),process.execArgv.forEach((function(e){e.indexOf("--max-old-space-size")>-1&&n.push(e)})),Object.assign({},e,{forkArgs:e.forkArgs,forkOpts:Object.assign({},e.forkOpts,{execArgv:(e.forkOpts&&e.forkOpts.execArgv||[]).concat(n)})})}function w(e,r){var n=this,i=r||{};function c(e){for(var r in n.terminated=!0,n.processing)void 0!==n.processing[r]&&n.processing[r].resolver.reject(e);n.processing=Object.create(null)}this.script=e||function(){if("browser"===s.platform){if("undefined"==typeof Blob)throw new Error("Blob not supported by the browser");if(!window.URL||"function"!=typeof window.URL.createObjectURL)throw new Error("URL.createObjectURL not supported by the browser");var e=new Blob([t(670)],{type:"text/javascript"});return window.URL.createObjectURL(e)}return __dirname+"/worker.js"}(),this.worker=function(e,r){if("web"===r.workerType)return f(),d(e,Worker);if("thread"===r.workerType)return l(e,t=a());if("process"!==r.workerType&&r.workerType){if("browser"===s.platform)return f(),d(e,Worker);var t=p();return t?l(e,t):h(e,k(r),u("child_process"))}return h(e,k(r),u("child_process"))}(this.script,i),this.debugPort=i.debugPort,e||(this.worker.ready=!0),this.requestQueue=[],this.worker.on("message",(function(e){if("string"==typeof e&&"ready"===e)n.worker.ready=!0,function(){var e,r=function(e,r){var t;if("undefined"==typeof Symbol||null==e[Symbol.iterator]){if(Array.isArray(e)||(t=function(e,r){if(e){if("string"==typeof e)return o(e,r);var t=Object.prototype.toString.call(e).slice(8,-1);return"Object"===t&&e.constructor&&(t=e.constructor.name),"Map"===t||"Set"===t?Array.from(e):"Arguments"===t||/^(?:Ui|I)nt(?:8|16|32)(?:Clamped)?Array$/.test(t)?o(e,r):void 0}}(e))||r&&e&&"number"==typeof e.length){t&&(e=t);var n=0,i=function(){};return{s:i,n:function(){return n>=e.length?{done:!0}:{done:!1,value:e[n++]}},e:function(e){throw e},f:i}}throw new TypeError("Invalid attempt to iterate non-iterable instance.\nIn order to be iterable, non-array objects must have a [Symbol.iterator]() method.")}var s,u=!0,c=!1;return{s:function(){t=e[Symbol.iterator]()},n:function(){var e=t.next();return u=e.done,e},e:function(e){c=!0,s=e},f:function(){try{u||null==t.return||t.return()}finally{if(c)throw s}}}}(n.requestQueue.splice(0));try{for(r.s();!(e=r.n()).done;){var t=e.value;n.worker.send(t)}}catch(e){r.e(e)}finally{r.f()}}();else{var r=e.id,t=n.processing[r];void 0!==t&&(e.isEvent?t.options&&"function"==typeof t.options.on&&t.options.on(e.payload):(delete n.processing[r],!0===n.terminating&&n.terminate(),e.error?t.resolver.reject(function(e){for(var r=new Error(""),t=Object.keys(e),o=0;o<t.length;o++)r[t[o]]=e[t[o]];return r}(e.error)):t.resolver.resolve(e.result)))}}));var w=this.worker;this.worker.on("error",c),this.worker.on("exit",(function(e,r){var t="Workerpool Worker terminated Unexpectedly\n";t+=" exitCode: `"+e+"`\n",t+=" signalCode: `"+r+"`\n",t+=" workerpool.script: `"+n.script+"`\n",t+=" spawnArgs: `"+w.spawnargs+"`\n",t+=" spawnfile: `"+w.spawnfile+"`\n",t+=" stdout: `"+w.stdout+"`\n",t+=" stderr: `"+w.stderr+"`\n",c(new Error(t))})),this.processing=Object.create(null),this.terminating=!1,this.terminated=!1,this.terminationHandler=null,this.lastId=0}w.prototype.methods=function(){return this.exec("methods")},w.prototype.exec=function(e,r,t,o){t||(t=i.defer());var n=++this.lastId;this.processing[n]={id:n,resolver:t,options:o};var s={id:n,method:e,params:r};this.terminated?t.reject(new Error("Worker is terminated")):this.worker.ready?this.worker.send(s):this.requestQueue.push(s);var u=this;return t.promise.catch((function(e){if(e instanceof i.CancellationError||e instanceof i.TimeoutError)return delete u.processing[n],u.terminateAndNotify(!0).then((function(){throw e}),(function(e){throw e}));throw e}))},w.prototype.busy=function(){return Object.keys(this.processing).length>0},w.prototype.terminate=function(e,r){var t=this;if(e){for(var o in this.processing)void 0!==this.processing[o]&&this.processing[o].resolver.reject(new Error("Worker terminated"));this.processing=Object.create(null)}if("function"==typeof r&&(this.terminationHandler=r),this.busy())this.terminating=!0;else{var n=function(e){if(t.terminated=!0,t.worker=null,t.terminating=!1,t.terminationHandler)t.terminationHandler(e,t);else if(e)throw e};if(this.worker){if("function"==typeof this.worker.kill){if(this.worker.killed)return void n(new Error("worker already killed!"));if(this.worker.isChildProcess){var i=setTimeout((function(){t.worker.kill()}),1e3);this.worker.once("exit",(function(){clearTimeout(i),t.worker.killed=!0,n()})),this.worker.ready?this.worker.send(c):this.worker.requestQueue.push(c)}else this.worker.kill(),this.worker.killed=!0,n();return}if("function"!=typeof this.worker.terminate)throw new Error("Failed to terminate worker");this.worker.terminate(),this.worker.killed=!0}n()}},w.prototype.terminateAndNotify=function(e,r){var t=i.defer();return r&&(t.promise.timeout=r),this.terminate(e,(function(e,r){e?t.reject(e):t.resolve(r)})),t.promise},e.exports=w,e.exports._tryRequireWorkerThreads=p,e.exports._setupProcessWorker=h,e.exports._setupBrowserWorker=d,e.exports._setupWorkerThreadWorker=l,e.exports.ensureWorkerThreads=a},833:function(e){"use strict";function r(){this.ports=Object.create(null),this.length=0}e.exports=r,r.prototype.nextAvailableStartingAt=function(e){for(;!0===this.ports[e];)e++;if(e>=65535)throw new Error("WorkerPool debug port limit reached: "+e+">= 65535");return this.ports[e]=!0,this.length++,e},r.prototype.releasePort=function(e){delete this.ports[e],this.length--}},828:function(e,r,t){var o=t(397),n=function(e){return void 0!==e&&null!=e.versions&&null!=e.versions.node};e.exports.isNode=n,e.exports.platform="undefined"!=typeof process&&n(process)?"node":"browser";var i=function(e){try{return o("worker_threads")}catch(e){return null}}();e.exports.isMainThread="node"===e.exports.platform?(!i||i.isMainThread)&&!process.connected:"undefined"!=typeof Window,e.exports.cpus="browser"===e.exports.platform?self.navigator.hardwareConcurrency:o("os").cpus().length},670:function(e){e.exports='!function(){var __webpack_modules__={744:function(__unused_webpack_module,exports){var __webpack_unused_export__;function _typeof(e){return(_typeof="function"==typeof Symbol&&"symbol"==typeof Symbol.iterator?function(e){return typeof e}:function(e){return e&&"function"==typeof Symbol&&e.constructor===Symbol&&e!==Symbol.prototype?"symbol":typeof e})(e)}var requireFoolWebpack=eval("typeof require !== \'undefined\' ? require : function (module) { throw new Error(\'Module \\" + module + \\" not found.\') }"),TERMINATE_METHOD_ID="__workerpool-terminate__",worker={exit:function(){}},WorkerThreads,parentPort;if("undefined"!=typeof self&&"function"==typeof postMessage&&"function"==typeof addEventListener)worker.on=function(e,r){addEventListener(e,function(e){r(e.data)})},worker.send=function(e){postMessage(e)};else{if("undefined"==typeof process)throw new Error("Script must be executed as a worker");try{WorkerThreads=requireFoolWebpack("worker_threads")}catch(error){if("object"!==_typeof(error)||null===error||"MODULE_NOT_FOUND"!==error.code)throw error}WorkerThreads&&null!==WorkerThreads.parentPort?(parentPort=WorkerThreads.parentPort,worker.send=parentPort.postMessage.bind(parentPort),worker.on=parentPort.on.bind(parentPort)):(worker.on=process.on.bind(process),worker.send=process.send.bind(process),worker.on("disconnect",function(){process.exit(1)}),worker.exit=process.exit.bind(process))}function convertError(o){return Object.getOwnPropertyNames(o).reduce(function(e,r){return Object.defineProperty(e,r,{value:o[r],enumerable:!0})},{})}function isPromise(e){return e&&"function"==typeof e.then&&"function"==typeof e.catch}worker.methods={},worker.methods.run=function(e,r){e=new Function("return ("+e+").apply(null, arguments);");return e.apply(e,r)},worker.methods.methods=function(){return Object.keys(worker.methods)};var currentRequestId=null;worker.on("message",function(r){if(r===TERMINATE_METHOD_ID)return worker.exit(0);try{var e=worker.methods[r.method];if(!e)throw new Error(\'Unknown method "\'+r.method+\'"\');currentRequestId=r.id;e=e.apply(e,r.params);isPromise(e)?e.then(function(e){worker.send({id:r.id,result:e,error:null}),currentRequestId=null}).catch(function(e){worker.send({id:r.id,result:null,error:convertError(e)}),currentRequestId=null}):(worker.send({id:r.id,result:e,error:null}),currentRequestId=null)}catch(e){worker.send({id:r.id,result:null,error:convertError(e)})}}),worker.register=function(e){if(e)for(var r in e)e.hasOwnProperty(r)&&(worker.methods[r]=e[r]);worker.send("ready")},worker.emit=function(e){currentRequestId&&worker.send({id:currentRequestId,isEvent:!0,payload:e})},__webpack_unused_export__=worker.register,__webpack_unused_export__=worker.emit}},__webpack_module_cache__={};function __webpack_require__(e){if(__webpack_module_cache__[e])return __webpack_module_cache__[e].exports;var r=__webpack_module_cache__[e]={exports:{}};return __webpack_modules__[e](r,r.exports,__webpack_require__),r.exports}__webpack_require__(744)}();'},352:function(e,r,t){var o=t(828);r.pool=function(e,r){return new(t(345))(e,r)},r.worker=function(e){t(744).add(e)},r.workerEmit=function(e){t(744).emit(e)},r.Promise=t(219),r.platform=o.platform,r.isMainThread=o.isMainThread,r.cpus=o.cpus},397:function(module){var requireFoolWebpack=eval("typeof require !== 'undefined' ? require : function (module) { throw new Error('Module \" + module + \" not found.') }");module.exports=requireFoolWebpack},744:function(__unused_webpack_module,exports){function _typeof(e){return(_typeof="function"==typeof Symbol&&"symbol"==typeof Symbol.iterator?function(e){return typeof e}:function(e){return e&&"function"==typeof Symbol&&e.constructor===Symbol&&e!==Symbol.prototype?"symbol":typeof e})(e)}var requireFoolWebpack=eval("typeof require !== 'undefined' ? require : function (module) { throw new Error('Module \" + module + \" not found.') }"),TERMINATE_METHOD_ID="__workerpool-terminate__",worker={exit:function(){}};if("undefined"!=typeof self&&"function"==typeof postMessage&&"function"==typeof addEventListener)worker.on=function(e,r){addEventListener(e,(function(e){r(e.data)}))},worker.send=function(e){postMessage(e)};else{if("undefined"==typeof process)throw new Error("Script must be executed as a worker");var WorkerThreads;try{WorkerThreads=requireFoolWebpack("worker_threads")}catch(e){if("object"!==_typeof(e)||null===e||"MODULE_NOT_FOUND"!==e.code)throw e}if(WorkerThreads&&null!==WorkerThreads.parentPort){var parentPort=WorkerThreads.parentPort;worker.send=parentPort.postMessage.bind(parentPort),worker.on=parentPort.on.bind(parentPort)}else worker.on=process.on.bind(process),worker.send=process.send.bind(process),worker.on("disconnect",(function(){process.exit(1)})),worker.exit=process.exit.bind(process)}function convertError(e){return Object.getOwnPropertyNames(e).reduce((function(r,t){return Object.defineProperty(r,t,{value:e[t],enumerable:!0})}),{})}function isPromise(e){return e&&"function"==typeof e.then&&"function"==typeof e.catch}worker.methods={},worker.methods.run=function(e,r){var t=new Function("return ("+e+").apply(null, arguments);");return t.apply(t,r)},worker.methods.methods=function(){return Object.keys(worker.methods)};var currentRequestId=null;worker.on("message",(function(e){if(e===TERMINATE_METHOD_ID)return worker.exit(0);try{var r=worker.methods[e.method];if(!r)throw new Error('Unknown method "'+e.method+'"');currentRequestId=e.id;var t=r.apply(r,e.params);isPromise(t)?t.then((function(r){worker.send({id:e.id,result:r,error:null}),currentRequestId=null})).catch((function(r){worker.send({id:e.id,result:null,error:convertError(r)}),currentRequestId=null})):(worker.send({id:e.id,result:t,error:null}),currentRequestId=null)}catch(r){worker.send({id:e.id,result:null,error:convertError(r)})}})),worker.register=function(e){if(e)for(var r in e)e.hasOwnProperty(r)&&(worker.methods[r]=e[r]);worker.send("ready")},worker.emit=function(e){currentRequestId&&worker.send({id:currentRequestId,isEvent:!0,payload:e})},exports.add=worker.register,exports.emit=worker.emit}},__webpack_module_cache__={};function __webpack_require__(e){if(__webpack_module_cache__[e])return __webpack_module_cache__[e].exports;var r=__webpack_module_cache__[e]={exports:{}};return __webpack_modules__[e](r,r.exports,__webpack_require__),r.exports}return __webpack_require__(352)}()}));
//# sourceMappingURL=workerpool.min.js.map

4

dist/workerpool.min.js.LICENSE.txt

@@ -7,4 +7,4 @@ /**

*
* @version 6.0.4
* @date 2021-01-16
* @version 6.1.0
* @date 2021-01-31
*

@@ -11,0 +11,0 @@ * @license

8

HISTORY.md
# workerpool history
https://github.com/josdejong/workerpool
## 2021-01-31, version 6.1.0
- Implemented support for sending events from the worker to the main thread,
see #51, #227. Thanks @Akryum.
- Fix an issue in Node.js nightly, see #230. Thanks @aduh95.
- Fix #232 `workerpool` not working on IE 10.
## 2021-01-16, version 6.0.4

@@ -5,0 +13,0 @@

9

package.json
{
"name": "workerpool",
"license": "Apache-2.0",
"version": "6.0.4",
"version": "6.1.0",
"description": "Offload tasks to a pool of workers on node.js and in the browser",

@@ -37,2 +37,5 @@ "homepage": "https://github.com/josdejong/workerpool",

"devDependencies": {
"@babel/core": "7.12.10",
"@babel/preset-env": "7.12.11",
"babel-loader": "8.2.2",
"date-format": "3.0.0",

@@ -46,6 +49,6 @@ "del": "6.0.0",

"mocha": "8.2.1",
"uglify-js": "3.12.4",
"webpack": "5.15.0"
"uglify-js": "3.12.5",
"webpack": "5.19.0"
},
"dependencies": {}
}

50

README.md

@@ -205,6 +205,8 @@ # workerpool

- `Pool.exec(method: Function | string, params: Array | null) : Promise.<*, Error>`<br>
- `Pool.exec(method: Function | string, params: Array | null [, options: Object]) : Promise.<*, Error>`<br>
Execute a function on a worker with given arguments.
- When `method` is a string, a method with this name must exist at the worker and must be registered to make it accessible via the pool. The function will be executed on the worker with given parameters.
- When `method` is a function, the provided function `fn` will be stringified, send to the worker, and executed there with the provided parameters. The provided function must be static, it must not depend on variables in a surrounding scope.
- The following options are available:
- `on: (payload: any) => void`. An event listener, to handle events sent by the worker for this execution. See [Events](#events) for more details.

@@ -343,2 +345,48 @@ - `Pool.proxy() : Promise.<Object, Error>`<br>

### Events
You can send data back from workers to the pool while the task is being executed using the `workerEmit` function:
`workerEmit(payload: any)`
This function only works inside a worker **and** during a task.
Example:
```js
// file myWorker.js
const workerpool = require('workerpool');
function eventExample(delay) {
workerpool.workerEmit({
status: 'in_progress'
});
workerpool.workerEmit({
status: 'complete'
});
return true;
}
// create a worker and register functions
workerpool.worker({
eventExample: eventExample
});
```
To receive those events, you can use the `on` option of the pool `exec` method:
```js
pool.exec('eventExample', [], {
on: function (payload) {
if (payload.status === 'in_progress') {
console.log('In progress...');
} else if (payload.status === 'complete') {
console.log('Done!');
}
}
})
```
### Utilities

@@ -345,0 +393,0 @@

2

src/generated/embeddedWorker.js

@@ -6,2 +6,2 @@ /**

*/
module.exports = "(()=>{var __webpack_modules__={736:(__unused_webpack_module,exports)=>{var __webpack_unused_export__,requireFoolWebpack=eval(\"typeof require !== 'undefined' ? require : function (module) { throw new Error('Module \\\" + module + \\\" not found.') }\"),TERMINATE_METHOD_ID=\"__workerpool-terminate__\",worker={exit:function(){}},WorkerThreads,parentPort;if(\"undefined\"!=typeof self&&\"function\"==typeof postMessage&&\"function\"==typeof addEventListener)worker.on=function(e,r){addEventListener(e,function(e){r(e.data)})},worker.send=function(e){postMessage(e)};else{if(\"undefined\"==typeof process)throw new Error(\"Script must be executed as a worker\");try{WorkerThreads=requireFoolWebpack(\"worker_threads\")}catch(error){if(\"object\"!=typeof error||null===error||\"MODULE_NOT_FOUND\"!==error.code)throw error}WorkerThreads&&null!==WorkerThreads.parentPort?(parentPort=WorkerThreads.parentPort,worker.send=parentPort.postMessage.bind(parentPort),worker.on=parentPort.on.bind(parentPort)):(worker.on=process.on.bind(process),worker.send=process.send.bind(process),worker.on(\"disconnect\",function(){process.exit(1)}),worker.exit=process.exit.bind(process))}function convertError(o){return Object.getOwnPropertyNames(o).reduce(function(e,r){return Object.defineProperty(e,r,{value:o[r],enumerable:!0})},{})}function isPromise(e){return e&&\"function\"==typeof e.then&&\"function\"==typeof e.catch}worker.methods={},worker.methods.run=function(e,r){e=new Function(\"return (\"+e+\").apply(null, arguments);\");return e.apply(e,r)},worker.methods.methods=function(){return Object.keys(worker.methods)},worker.on(\"message\",function(r){if(r===TERMINATE_METHOD_ID)return worker.exit(0);try{var e=worker.methods[r.method];if(!e)throw new Error('Unknown method \"'+r.method+'\"');e=e.apply(e,r.params);isPromise(e)?e.then(function(e){worker.send({id:r.id,result:e,error:null})}).catch(function(e){worker.send({id:r.id,result:null,error:convertError(e)})}):worker.send({id:r.id,result:e,error:null})}catch(e){worker.send({id:r.id,result:null,error:convertError(e)})}}),worker.register=function(e){if(e)for(var r in e)e.hasOwnProperty(r)&&(worker.methods[r]=e[r]);worker.send(\"ready\")},__webpack_unused_export__=worker.register}},__webpack_module_cache__={};function __webpack_require__(e){if(__webpack_module_cache__[e])return __webpack_module_cache__[e].exports;var r=__webpack_module_cache__[e]={exports:{}};return __webpack_modules__[e](r,r.exports,__webpack_require__),r.exports}__webpack_require__(736)})();";
module.exports = "!function(){var __webpack_modules__={744:function(__unused_webpack_module,exports){var __webpack_unused_export__;function _typeof(e){return(_typeof=\"function\"==typeof Symbol&&\"symbol\"==typeof Symbol.iterator?function(e){return typeof e}:function(e){return e&&\"function\"==typeof Symbol&&e.constructor===Symbol&&e!==Symbol.prototype?\"symbol\":typeof e})(e)}var requireFoolWebpack=eval(\"typeof require !== 'undefined' ? require : function (module) { throw new Error('Module \\\" + module + \\\" not found.') }\"),TERMINATE_METHOD_ID=\"__workerpool-terminate__\",worker={exit:function(){}},WorkerThreads,parentPort;if(\"undefined\"!=typeof self&&\"function\"==typeof postMessage&&\"function\"==typeof addEventListener)worker.on=function(e,r){addEventListener(e,function(e){r(e.data)})},worker.send=function(e){postMessage(e)};else{if(\"undefined\"==typeof process)throw new Error(\"Script must be executed as a worker\");try{WorkerThreads=requireFoolWebpack(\"worker_threads\")}catch(error){if(\"object\"!==_typeof(error)||null===error||\"MODULE_NOT_FOUND\"!==error.code)throw error}WorkerThreads&&null!==WorkerThreads.parentPort?(parentPort=WorkerThreads.parentPort,worker.send=parentPort.postMessage.bind(parentPort),worker.on=parentPort.on.bind(parentPort)):(worker.on=process.on.bind(process),worker.send=process.send.bind(process),worker.on(\"disconnect\",function(){process.exit(1)}),worker.exit=process.exit.bind(process))}function convertError(o){return Object.getOwnPropertyNames(o).reduce(function(e,r){return Object.defineProperty(e,r,{value:o[r],enumerable:!0})},{})}function isPromise(e){return e&&\"function\"==typeof e.then&&\"function\"==typeof e.catch}worker.methods={},worker.methods.run=function(e,r){e=new Function(\"return (\"+e+\").apply(null, arguments);\");return e.apply(e,r)},worker.methods.methods=function(){return Object.keys(worker.methods)};var currentRequestId=null;worker.on(\"message\",function(r){if(r===TERMINATE_METHOD_ID)return worker.exit(0);try{var e=worker.methods[r.method];if(!e)throw new Error('Unknown method \"'+r.method+'\"');currentRequestId=r.id;e=e.apply(e,r.params);isPromise(e)?e.then(function(e){worker.send({id:r.id,result:e,error:null}),currentRequestId=null}).catch(function(e){worker.send({id:r.id,result:null,error:convertError(e)}),currentRequestId=null}):(worker.send({id:r.id,result:e,error:null}),currentRequestId=null)}catch(e){worker.send({id:r.id,result:null,error:convertError(e)})}}),worker.register=function(e){if(e)for(var r in e)e.hasOwnProperty(r)&&(worker.methods[r]=e[r]);worker.send(\"ready\")},worker.emit=function(e){currentRequestId&&worker.send({id:currentRequestId,isEvent:!0,payload:e})},__webpack_unused_export__=worker.register,__webpack_unused_export__=worker.emit}},__webpack_module_cache__={};function __webpack_require__(e){if(__webpack_module_cache__[e])return __webpack_module_cache__[e].exports;var r=__webpack_module_cache__[e]={exports:{}};return __webpack_modules__[e](r,r.exports,__webpack_require__),r.exports}__webpack_require__(744)}();";

9

src/index.js

@@ -25,2 +25,11 @@ var environment = require('./environment');

/**
* Sends an event to the parent worker pool.
* @param {any} payload
*/
exports.workerEmit = function workerEmit(payload) {
var worker = require('./worker');
worker.emit(payload);
};
/**
* Create a promise.

@@ -27,0 +36,0 @@ * @type {Promise} promise

10

src/Pool.js

@@ -91,5 +91,6 @@ var Promise = require('./Promise');

* @param {Array} [params] Function arguments applied when calling the function
* @param {ExecOptions} [options] Options object
* @return {Promise.<*, Error>} result
*/
Pool.prototype.exec = function (method, params) {
Pool.prototype.exec = function (method, params, options) {
// validate type of arguments

@@ -113,3 +114,4 @@ if (params && !Array.isArray(params)) {

resolver: resolver,
timeout: null
timeout: null,
options: options
};

@@ -207,3 +209,3 @@ tasks.push(task);

// send the request to the worker
var promise = worker.exec(task.method, task.params, task.resolver)
var promise = worker.exec(task.method, task.params, task.resolver, task.options)
.then(me._boundNext)

@@ -261,3 +263,3 @@ .catch(function () {

/**
* Remove a worker from the pool.
* Remove a worker from the pool.
* Attempts to terminate worker if not already terminated, and ensures the minimum

@@ -264,0 +266,0 @@ * pool size is met.

7

src/types.js

@@ -10,2 +10,7 @@ /**

* @property {number} [debugPortStart]
*/
*/
/**
* @typedef {Object} ExecOptions
* @property {(payload: any) => unknown} [on]
*/

19

src/worker.js

@@ -112,2 +112,4 @@ /**

var currentRequestId = null;
worker.on('message', function (request) {

@@ -121,2 +123,4 @@ if (request === TERMINATE_METHOD_ID) {

if (method) {
currentRequestId = request.id;
// execute the function

@@ -134,2 +138,3 @@ var result = method.apply(method, request.params);

});
currentRequestId = null;
})

@@ -142,2 +147,3 @@ .catch(function (err) {

});
currentRequestId = null;
});

@@ -152,2 +158,4 @@ }

});
currentRequestId = null;
}

@@ -186,4 +194,15 @@ }

worker.emit = function (payload) {
if (currentRequestId) {
worker.send({
id: currentRequestId,
isEvent: true,
payload
});
}
};
if (typeof exports !== 'undefined') {
exports.add = worker.register;
exports.emit = worker.emit;
}

43

src/WorkerHandler.js

@@ -227,18 +227,24 @@ 'use strict';

if (task !== undefined) {
// remove the task from the queue
delete me.processing[id];
if (response.isEvent) {
if (task.options && typeof task.options.on === 'function') {
task.options.on(response.payload);
}
} else {
// remove the task from the queue
delete me.processing[id];
// test if we need to terminate
if (me.terminating === true) {
// complete worker termination if all tasks are finished
me.terminate();
}
// test if we need to terminate
if (me.terminating === true) {
// complete worker termination if all tasks are finished
me.terminate();
}
// resolve the task's promise
if (response.error) {
task.resolver.reject(objectToError(response.error));
// resolve the task's promise
if (response.error) {
task.resolver.reject(objectToError(response.error));
}
else {
task.resolver.resolve(response.result);
}
}
else {
task.resolver.resolve(response.result);
}
}

@@ -263,4 +269,5 @@ }

{
me.requestQueue.forEach(me.worker.send.bind(me.worker));
me.requestQueue = [];
for(const request of me.requestQueue.splice(0)) {
me.worker.send(request);
}
}

@@ -308,5 +315,6 @@

* @param {{resolve: Function, reject: Function}} [resolver]
* @param {ExecOptions} [options]
* @return {Promise.<*, Error>} result
*/
WorkerHandler.prototype.exec = function(method, params, resolver) {
WorkerHandler.prototype.exec = function(method, params, resolver, options) {
if (!resolver) {

@@ -322,3 +330,4 @@ resolver = Promise.defer();

id: id,
resolver: resolver
resolver: resolver,
options: options
};

@@ -325,0 +334,0 @@ 

dist/worker.js.map

Sorry, the diff of this file is not supported yet

dist/workerpool.js.map

Sorry, the diff of this file is not supported yet

dist/workerpool.min.js.map

Sorry, the diff of this file is not supported yet

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

About

Packages

npm

Go

Maven

PyPI

Rubygems

Stay in touch

Get open source security insights delivered straight into your inbox.

  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc