У меня есть процесс CLI, который использует ReactPhp \ childProcess для создания параллельных процессов, в среднем 600 из них, но может быть больше.
Каждый процесс условной выполняет операции A, B, C ... z , каждая операция имеет свои пределы выполнения, I.E. a = 10, b = 15 loop->addTimer(30, function() use ($process) {
$process->start($this->loop);
});
});
$process->start($this->loop);
}
$this->loop->run();
}
}
< /code>
worker.php
// Class Worker CLI command
class WorkerCmd
{
public function action(int $id)
{
$worker = ... // get some worker info by $id;
$operations = $worker->getOperations(); // get list of 'A', 'B'... 'Z' operation how this worker can solve
$redis = new \Redis(/* connection info */);
/**
* $operationName look like string, example 'A'
* $operationData look like array:
* [
* 'throttle_cnt' => 15,
* ...
* ]
*/
foreach ($operations as $operationName => $operationData) {
... // some logic before reserved this operation
// Operation ready to reserve
// !!! WARNING This is "Bottleneck" Redis is to slow for meany workers and operation, need the alternative thing
$count = $redis->incr($operationName);
if ($count > $operationData['throttle_cnt']) {
$redis->decr($operationName);
continue;
}
// Some logic with execution this operation
$operationName($operationData);
$redis->decr($operationName);
}
}
}
Подробнее здесь: https://stackoverflow.com/questions/797 ... -processes
Лучший выбор для подсчета количества операций в параллельных процессах PHP ⇐ Php
Кемеровские программисты php общаются здесь
1753960945
Anonymous
У меня есть процесс CLI, который использует ReactPhp \ childProcess для создания параллельных процессов, в среднем 600 из них, но может быть больше.
Каждый процесс условной выполняет операции A, B, C ... z , каждая операция имеет свои пределы выполнения, I.E. a = 10, b = 15 loop->addTimer(30, function() use ($process) {
$process->start($this->loop);
});
});
$process->start($this->loop);
}
$this->loop->run();
}
}
< /code>
worker.php
// Class Worker CLI command
class WorkerCmd
{
public function action(int $id)
{
$worker = ... // get some worker info by $id;
$operations = $worker->getOperations(); // get list of 'A', 'B'... 'Z' operation how this worker can solve
$redis = new \Redis(/* connection info */);
/**
* $operationName look like string, example 'A'
* $operationData look like array:
* [
* 'throttle_cnt' => 15,
* ...
* ]
*/
foreach ($operations as $operationName => $operationData) {
... // some logic before reserved this operation
// Operation ready to reserve
// !!! WARNING This is "Bottleneck" Redis is to slow for meany workers and operation, need the alternative thing
$count = $redis->incr($operationName);
if ($count > $operationData['throttle_cnt']) {
$redis->decr($operationName);
continue;
}
// Some logic with execution this operation
$operationName($operationData);
$redis->decr($operationName);
}
}
}
Подробнее здесь: [url]https://stackoverflow.com/questions/79721118/the-best-choice-for-counting-the-number-of-operations-in-parallel-php-processes[/url]
Ответить
1 сообщение
• Страница 1 из 1
Перейти
- Кемерово-IT
- ↳ Javascript
- ↳ C#
- ↳ JAVA
- ↳ Elasticsearch aggregation
- ↳ Python
- ↳ Php
- ↳ Android
- ↳ Html
- ↳ Jquery
- ↳ C++
- ↳ IOS
- ↳ CSS
- ↳ Excel
- ↳ Linux
- ↳ Apache
- ↳ MySql
- Детский мир
- Для души
- ↳ Музыкальные инструменты даром
- ↳ Печатная продукция даром
- Внешняя красота и здоровье
- ↳ Одежда и обувь для взрослых даром
- ↳ Товары для здоровья
- ↳ Физкультура и спорт
- Техника - даром!
- ↳ Автомобилистам
- ↳ Компьютерная техника
- ↳ Плиты: газовые и электрические
- ↳ Холодильники
- ↳ Стиральные машины
- ↳ Телевизоры
- ↳ Телефоны, смартфоны, плашеты
- ↳ Швейные машинки
- ↳ Прочая электроника и техника
- ↳ Фототехника
- Ремонт и интерьер
- ↳ Стройматериалы, инструмент
- ↳ Мебель и предметы интерьера даром
- ↳ Cантехника
- Другие темы
- ↳ Разное даром
- ↳ Давай меняться!
- ↳ Отдам\возьму за копеечку
- ↳ Работа и подработка в Кемерове
- ↳ Давай с тобой поговорим...
Мобильная версия