}
expect(results.size).toBe(max)
await pool.destroy()
pool = new FixedThreadPool(max, './tests/worker-files/thread/testWorker.js')
results = new Set()
for (let i = 0; i < max; i++) {
}
expect(results.size).toBe(max)
await pool.destroy()
pool = new FixedThreadPool(max, './tests/worker-files/thread/testWorker.js')
results = new Set()
for (let i = 0; i < max; i++) {
.getWorkerChoiceStrategy()
.workerLastVirtualTaskTimestamp.keys()) {
expect(
pool.workerChoiceStrategyContext
.getWorkerChoiceStrategy()
.getWorkerChoiceStrategy()
.workerLastVirtualTaskTimestamp.keys()) {
expect(
pool.workerChoiceStrategyContext
.getWorkerChoiceStrategy()
.getWorkerChoiceStrategy()
.workerLastVirtualTaskTimestamp.keys()) {
expect(
pool.workerChoiceStrategyContext
.getWorkerChoiceStrategy()
.getWorkerChoiceStrategy()
.workerLastVirtualTaskTimestamp.keys()) {
expect(
pool.workerChoiceStrategyContext
.getWorkerChoiceStrategy()
.workerChoiceStrategy.workerLastVirtualTaskTimestamp
).toBeUndefined()
pool.setWorkerChoiceStrategy(WorkerChoiceStrategies.FAIR_SHARE)
.workerChoiceStrategy.workerLastVirtualTaskTimestamp
).toBeUndefined()
pool.setWorkerChoiceStrategy(WorkerChoiceStrategies.FAIR_SHARE)
.getWorkerChoiceStrategy()
.workerChoiceStrategy.workerLastVirtualTaskTimestamp.keys()) {
expect(
pool.workerChoiceStrategyContext
.getWorkerChoiceStrategy()
.getWorkerChoiceStrategy()
.workerChoiceStrategy.workerLastVirtualTaskTimestamp.keys()) {
expect(
pool.workerChoiceStrategyContext
.getWorkerChoiceStrategy()
.getWorkerChoiceStrategy()
.workersTaskRunTime.keys()) {
expect(
pool.workerChoiceStrategyContext
.getWorkerChoiceStrategy()
.getWorkerChoiceStrategy()
.workersTaskRunTime.keys()) {
expect(
pool.workerChoiceStrategyContext
.getWorkerChoiceStrategy()
.getWorkerChoiceStrategy()
.workersTaskRunTime.keys()) {
expect(
pool.workerChoiceStrategyContext
.getWorkerChoiceStrategy()
.getWorkerChoiceStrategy()
.workersTaskRunTime.keys()) {
expect(
pool.workerChoiceStrategyContext
.getWorkerChoiceStrategy()
.getWorkerChoiceStrategy()
.workerChoiceStrategy.workersTaskRunTime.keys()) {
expect(
pool.workerChoiceStrategyContext
.getWorkerChoiceStrategy()
.getWorkerChoiceStrategy()
.workerChoiceStrategy.workersTaskRunTime.keys()) {
expect(
pool.workerChoiceStrategyContext
.getWorkerChoiceStrategy()