(task: QueueChildMessage)
| 153 | } |
| 154 | |
| 155 | private _push(task: QueueChildMessage): Farm { |
| 156 | this._taskQueue.enqueue(task); |
| 157 | |
| 158 | const offset = this._getNextWorkerOffset(); |
| 159 | for (let i = 0; i < this._numOfWorkers; i++) { |
| 160 | this._process((offset + i) % this._numOfWorkers); |
| 161 | |
| 162 | if (task.request[1]) { |
| 163 | break; |
| 164 | } |
| 165 | } |
| 166 | |
| 167 | return this; |
| 168 | } |
| 169 | |
| 170 | private _getNextWorkerOffset(): number { |
| 171 | switch (this._workerSchedulingPolicy) { |
no test coverage detected