+ const promises = []
+ for (let i = 0; i < numberOfWorkers * 2; i++) {
+ promises.push(pool.execute())
+ }
+ for (const workerItem of pool.workers) {
+ expect(workerItem.tasksUsage).toBeDefined()
+ expect(workerItem.tasksUsage.run).toBe(0)
+ expect(workerItem.tasksUsage.running).toBe(numberOfWorkers * 2)
+ expect(workerItem.tasksUsage.runTime).toBe(0)
+ expect(workerItem.tasksUsage.avgRunTime).toBe(0)
+ expect(workerItem.tasksUsage.error).toBe(0)
+ }
+ await Promise.all(promises)
+ for (const workerItem of pool.workers) {
+ expect(workerItem.tasksUsage).toBeDefined()
+ expect(workerItem.tasksUsage.run).toBe(numberOfWorkers * 2)
+ expect(workerItem.tasksUsage.running).toBe(0)
+ expect(workerItem.tasksUsage.runTime).toBeGreaterThanOrEqual(0)
+ expect(workerItem.tasksUsage.avgRunTime).toBeGreaterThanOrEqual(0)
+ expect(workerItem.tasksUsage.error).toBe(0)
+ }
+ await pool.destroy()