| @@ 66-76 (lines=11) @@ | ||
| 63 | /** |
|
| 64 | * @return void |
|
| 65 | */ |
|
| 66 | protected function runQueueProcesses(): void |
|
| 67 | { |
|
| 68 | $numberOfProcesses = $this->getNumberOfParallelProcesses(); |
|
| 69 | for ($i = 0; $i < $numberOfProcesses; $i++) { |
|
| 70 | $this->queue->attach(array_pop($this->requests)); |
|
| 71 | } |
|
| 72 | ||
| 73 | if ($this->queue->count() > 0) { |
|
| 74 | $this->queue->send(); |
|
| 75 | } |
|
| 76 | } |
|
| 77 | ||
| 78 | /** |
|
| 79 | * @return int |
|
| @@ 122-131 (lines=10) @@ | ||
| 119 | /** |
|
| 120 | * @return void |
|
| 121 | */ |
|
| 122 | protected function runQueueProcesses(): void |
|
| 123 | { |
|
| 124 | $numberOfProcesses = $this->getNumberOfParallelProcesses(); |
|
| 125 | for ($i = 0; $i < $numberOfProcesses; $i++) { |
|
| 126 | $this->queue->attach(array_pop($this->requests)); |
|
| 127 | } |
|
| 128 | if ($this->queue->count() > 0) { |
|
| 129 | $this->queue->send(); |
|
| 130 | } |
|
| 131 | } |
|
| 132 | ||
| 133 | /** |
|
| 134 | * @return int |
|