archtechx/tenancy
1
0
Fork 0
mirror of https://github.com/archtechx/tenancy.git synced 2025-12-12 23:34:03 +00:00
Code Activity

ParallelCommand: add -P option for bypassing MAX_PROCESSES

Browse source
This commit is contained in:
Samuel Štancl 2024-09-30 16:36:37 +02:00
parent 303b52d25a
commit c6ba62bdd0
1 changed files with 17 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

21
src/Concerns/ParallelCommand.php
View file

@ -14,7 +14,7 @@ use Symfony\Component\Console\Input\InputOption;
trait ParallelCommand trait ParallelCommand
{ {
public const MAX_PROCESSES = 32; public const MAX_PROCESSES = 24;
protected bool $runningConcurrently = false; protected bool $runningConcurrently = false;
abstract protected function childHandle(mixed ...$args): bool; abstract protected function childHandle(mixed ...$args): bool;
@ -28,6 +28,14 @@ trait ParallelCommand
'How many processes to spawn. Maximum value: ' . static::MAX_PROCESSES . ', recommended value: core count (use just -p)', 'How many processes to spawn. Maximum value: ' . static::MAX_PROCESSES . ', recommended value: core count (use just -p)',
-1, -1,
); );
$this->addOption(
'forceProcesses',
'P',
InputOption::VALUE_OPTIONAL,
'Same as --processes but without a maximum value. Use at your own risk',
-1,
);
} }
protected function forkProcess(mixed ...$args): int protected function forkProcess(mixed ...$args): int
@ -91,7 +99,12 @@ trait ParallelCommand
protected function getProcesses(): int protected function getProcesses(): int
{ {
$processes = $this->input->getOption('processes'); $processes = $this->input->getOption('forceProcesses');
$forceProcesses = $processes !== -1;
if ($processes === -1) {
$processes = $this->input->getOption('processes');
}
if ($processes === null) { if ($processes === null) {
// This is used when the option is set but *without* a value (-p). // This is used when the option is set but *without* a value (-p).
@ -109,8 +122,8 @@ trait ParallelCommand
exit(1); exit(1);
} }
if ($processes > static::MAX_PROCESSES) { if ($processes > static::MAX_PROCESSES && ! $forceProcesses) {
$this->components->error('Maximum value for processes is ' . static::MAX_PROCESSES); $this->components->error('Maximum value for processes is ' . static::MAX_PROCESSES . ' provided value: ' . $processes);
exit(1); exit(1);
} }