@@ 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 |