Spaces:
Build error
Build error
| ; | |
| Object.defineProperty(exports, '__esModule', { | |
| value: true | |
| }); | |
| exports.default = void 0; | |
| var _BaseWorkerPool = _interopRequireDefault(require('./base/BaseWorkerPool')); | |
| function _interopRequireDefault(obj) { | |
| return obj && obj.__esModule ? obj : {default: obj}; | |
| } | |
| /** | |
| * Copyright (c) Facebook, Inc. and its affiliates. All Rights Reserved. | |
| * | |
| * This source code is licensed under the MIT license found in the | |
| * LICENSE file in the root directory of this source tree. | |
| */ | |
| const canUseWorkerThreads = () => { | |
| try { | |
| require('worker_threads'); | |
| return true; | |
| } catch { | |
| return false; | |
| } | |
| }; | |
| class WorkerPool extends _BaseWorkerPool.default { | |
| send(workerId, request, onStart, onEnd, onCustomMessage) { | |
| this.getWorkerById(workerId).send(request, onStart, onEnd, onCustomMessage); | |
| } | |
| createWorker(workerOptions) { | |
| let Worker; | |
| if (this._options.enableWorkerThreads && canUseWorkerThreads()) { | |
| Worker = require('./workers/NodeThreadsWorker').default; | |
| } else { | |
| Worker = require('./workers/ChildProcessWorker').default; | |
| } | |
| return new Worker(workerOptions); | |
| } | |
| } | |
| var _default = WorkerPool; | |
| exports.default = _default; | |