- case WorkerProcessType.WORKER_SET:
- if (Utils.isUndefined(options.elementsPerWorker)) {
- options.elementsPerWorker = 1;
- }
- return new WorkerSet<T>(workerScript, options.elementsPerWorker);
- case WorkerProcessType.STATIC_POOL:
- if (Utils.isUndefined(options.poolMaxSize)) {
- options.poolMaxSize = 16;
- }
- return new WorkerStaticPool<T>(workerScript, options.poolMaxSize);
- case WorkerProcessType.DYNAMIC_POOL:
- if (Utils.isUndefined(options.poolMinSize)) {
- options.poolMinSize = 4;
- }
- if (Utils.isUndefined(options.poolMaxSize)) {
- options.poolMaxSize = 16;
- }
- return new WorkerDynamicPool<T>(workerScript, options.poolMinSize, options.poolMaxSize);
+ case WorkerProcessType.workerSet:
+ return new WorkerSet<D, R>(workerScript, workerOptions)
+ case WorkerProcessType.fixedPool:
+ return new WorkerFixedPool<D, R>(workerScript, workerOptions)
+ case WorkerProcessType.dynamicPool:
+ return new WorkerDynamicPool<D, R>(workerScript, workerOptions)