@@ 111-123 (lines=13) @@ | ||
108 | * @param OutputInterface $output |
|
109 | * @return void |
|
110 | */ |
|
111 | protected function execute(InputInterface $input, OutputInterface $output) |
|
112 | { |
|
113 | $numberOfThreads = (int)$input->getArgument(self::ARGUMENT_NUMBER_OF_THREADS); |
|
114 | $customerIds = $this->customerIdsProvider->getCustomerIds(); |
|
115 | ||
116 | $this->timer->startTimer(); |
|
117 | ||
118 | $this->startProcesses($customerIds, $numberOfThreads); |
|
119 | ||
120 | $this->timer->stopTimer(); |
|
121 | ||
122 | $output->writeln("<info>Process finished after {$this->timer->getExecutionTimeInSeconds()} seconds</info>"); |
|
123 | } |
|
124 | ||
125 | /** |
|
126 | * @param int[] $customerIds |
@@ 124-136 (lines=13) @@ | ||
121 | * @param OutputInterface $output |
|
122 | * @return void |
|
123 | */ |
|
124 | protected function execute(InputInterface $input, OutputInterface $output) |
|
125 | { |
|
126 | $customerIds = $this->customerIdsProvider->getCustomerIds(); |
|
127 | $numberOfThreads = (int)$input->getArgument(self::ARGUMENT_NUMBER_OF_THREADS); |
|
128 | ||
129 | $this->timer->startTimer(); |
|
130 | ||
131 | $this->startProcesses($customerIds, $numberOfThreads); |
|
132 | ||
133 | $this->timer->stopTimer(); |
|
134 | ||
135 | $output->writeln("<info>Process finished after {$this->timer->getExecutionTimeInSeconds()} seconds</info>"); |
|
136 | } |
|
137 | ||
138 | /** |
|
139 | * @param array $customerIds |