| @@ 129-137 (lines=9) @@ | ||
| 126 | * @param int[] $customerIds |
|
| 127 | * @param int $numberOfThreads |
|
| 128 | */ |
|
| 129 | protected function startProcesses(array $customerIds, int $numberOfThreads): void |
|
| 130 | { |
|
| 131 | $chunkSize = $this->chunkSizeCalculator->calculateChunkSize($customerIds, $numberOfThreads); |
|
| 132 | $threadedCustomerIds = array_chunk($customerIds, $chunkSize); |
|
| 133 | foreach ($threadedCustomerIds as $customerIdsForSingleThread) { |
|
| 134 | $this->createProcessDefinition($this->getFullCommand($customerIdsForSingleThread)); |
|
| 135 | } |
|
| 136 | $this->loop->run(); |
|
| 137 | } |
|
| 138 | ||
| 139 | /** |
|
| 140 | * @param string $command |
|
| @@ 142-150 (lines=9) @@ | ||
| 139 | * @param array $customerIds |
|
| 140 | * @param int $numberOfThreads |
|
| 141 | */ |
|
| 142 | protected function startProcesses(array $customerIds, int $numberOfThreads): void |
|
| 143 | { |
|
| 144 | $chunkSize = $this->chunkSizeCalculator->calculateChunkSize($customerIds, $numberOfThreads); |
|
| 145 | $threadedCustomerIds = array_chunk($customerIds, $chunkSize); |
|
| 146 | foreach ($threadedCustomerIds as $customerIdsForSingleThread) { |
|
| 147 | $this->createRequestDefinition($customerIdsForSingleThread); |
|
| 148 | } |
|
| 149 | $this->loop->run(); |
|
| 150 | } |
|
| 151 | ||
| 152 | /** |
|
| 153 | * @param int[] $customerIds |
|