[{"_1":2,"_155":-5,"_156":-5},"loaderData",{"_3":4,"_13":14,"_21":22,"_134":135},"root",{"_5":-5,"_6":-7,"_7":8,"_9":-7,"_10":11,"_12":-7},"currentUser","primaryEmail","siteVerification","6LeIxAcTAAAAAJcZVRqyHh71UMIEGNQ_MXjiZKhI","toast","enableDev",false,"incidentStatus","routes/_layout",{"_15":-5,"_16":17,"_18":17,"_19":11,"_20":11},"username","isAskGordonEnabled",true,"isUsingNewTemplate","showMinimalLanding","showHoneypotTrap","routes/_layout.r.$namespace.$reponame",{"_23":24,"_25":-5,"_26":11,"_27":11,"_28":29,"_30":31,"_32":-5,"_33":11,"_34":35,"_84":-5,"_85":86,"_125":-5,"_126":11,"_127":17,"_128":11,"_129":-5,"_130":11,"_131":-5,"_132":133},"canonicalUrl","https://hub.docker.com/r/andreytech/parallel-executor-php-example/tags","mcpServer","canSeeDockerfile","canSeeAutobuilds","namespace","andreytech","reponame","parallel-executor-php-example","cloudBuildSource","isAutobuildsAvailable","repo",{"_36":37,"_38":39,"_41":42,"_43":44,"_45":11,"_46":47,"_48":49,"_50":51,"_53":31,"_28":29,"_54":55,"_56":40,"_57":58,"_59":60,"_61":62,"_63":-5,"_64":58,"_65":66,"_67":11,"_68":29,"_69":70,"_75":11,"_76":77,"_81":29,"_82":83},"categories",[],"content_types",[40],"image","date_registered","2020-08-06T10:26:16.531585Z","description","Пример работы класса ParallelExecutor на PHP7.4, основанного на PHP-расширении parallel","is_private","last_updated","2020-08-06T10:40:45.68787Z","last_modified","2024-10-16T13:48:34.145251Z","media_types",[52],"application/vnd.docker.container.image.v1+json","name","pull_count",97,"repository_type","star_count",0,"status",1,"status_description","active","source","collaborator_count","full_description","# Parallel Executor\n\nПример работы простого класса [ParallelExecutor](https://github.com/andrey-tech/parallel-executor-php), позволяющего выполнять задачи в нескольких параллельных потоках исполнения при помощи PHP-расширения [parallel](https://www.php.net/manual/ru/book.parallel.php).\n\n## Содержание\n\n\n- [Требования](#%D0%A2%D1%80%D0%B5%D0%B1%D0%BE%D0%B2%D0%B0%D0%BD%D0%B8%D1%8F)\n- [Установка](#%D0%A3%D1%81%D1%82%D0%B0%D0%BD%D0%BE%D0%B2%D0%BA%D0%B0)\n- [Класс `\\App\\ParallelExecutor`](#%D0%9A%D0%BB%D0%B0%D1%81%D1%81-appparallelexecutor)\n - [Методы класса](#%D0%9C%D0%B5%D1%82%D0%BE%D0%B4%D1%8B-%D0%BA%D0%BB%D0%B0%D1%81%D1%81%D0%B0)\n - [Дополнительные параметры](#%D0%94%D0%BE%D0%BF%D0%BE%D0%BB%D0%BD%D0%B8%D1%82%D0%B5%D0%BB%D1%8C%D0%BD%D1%8B%D0%B5-%D0%BF%D0%B0%D1%80%D0%B0%D0%BC%D0%B5%D1%82%D1%80%D1%8B)\n- [Примеры](#%D0%9F%D1%80%D0%B8%D0%BC%D0%B5%D1%80%D1%8B)\n- [Автор](#%D0%90%D0%B2%D1%82%D0%BE%D1%80)\n- [Лицензия](#%D0%9B%D0%B8%D1%86%D0%B5%D0%BD%D0%B7%D0%B8%D1%8F)\n\n\n\n\n## Требования\n\n- PHP >=7.2 Thread Safe.\n- PHP-расширение [parallel](https://www.php.net/manual/ru/book.parallel.php).\n- Произвольный автозагрузчик классов, реализующий стандарт [PSR-4](https://www.php-fig.org/psr/psr-4/).\n\n\n## Установка\n\nУстановка через composer:\n```\n$ composer require andrey-tech/parallel-executor:\"^1.0\"\n```\nили добавить\n```\n\"andrey-tech/parallel-executor\": \"^1.0\"\n```\nв секцию require файла composer.json.\n\n\n## Класс `\\App\\ParallelExecutor`\n\n\n### Методы класса\n\n- `__construct(int $threads = 5, string $channelName = __CLASS__, int $channelСapacity = Channel::Infinite)` \n Конструктор класса.\n * `$threads` - количество создаваемых сред исполнения, как отдельных потоков PHP;\n * `$channelName` - имя создаваемого именованного канала;\n * `$channelСapacity` - емкость создаваемого именованного канала, МиБ (0 - небуферизированный канал)\n- `execute(\\Closure $closure, array $argv = []) :void` \n Отправляет на исполнение переданную задачу.\n * `$closure` - функция-замыкание, исполняющяя задачу;\n * `$argv` - аргументы функции.\n\n\n### Дополнительные параметры\n\nДополнительные параметры устанавливаются через публичные статические свойства класса `\\App\\ParallelExecutor`:\n\nСвойство | По умолчанию | Описание\n----------------------- | ------------------ | --------\n`$autoloader` | '' | Устанавливает файл автозагрузчика классов, подключаемый в каждой среде исполнения\n\n\n## Примеры\n\nВыполнение 10 задач в 3 параллельных потоках PHP с буферизированным каналом:\n```php\n// Создаем исполнитель c 3-я отдельными параллельными потоками PHP и буферизированным каналом\n$executor = new \\App\\ParallelExecutor(3);\n\n$i = 0;\n$startTime = microtime(true);\nwhile ($i < 10) {\n $i++;\n printf(\"[%.4f] execute\" . PHP_EOL, microtime(true) - $startTime, $i);\n $executor->execute(\n function ($i) use ($startTime) {\n $sleep = random_int(1, 5);\n printf(\"[%.4f] %2d: Start sleeping {$sleep} s...\" . PHP_EOL, microtime(true) - $startTime, $i);\n sleep($sleep);\n printf(\"[%.4f] %2d: DONE\" . PHP_EOL, microtime(true) - $startTime, $i);\n },\n [ $i ]\n );\n}\n```\n\nРезультат:\n```\n[0.0000] execute\n[0.0001] execute\n[0.0002] execute\n[0.0002] 1: Start sleeping 5 s...\n[0.0002] execute\n[0.0003] 2: Start sleeping 4 s...\n[0.0003] execute\n[0.0003] 3: Start sleeping 5 s...\n[0.0003] execute\n[0.0004] execute\n[0.0004] execute\n[0.0004] execute\n[0.0005] execute\n[4.0008] 2: DONE\n[4.0010] 4: Start sleeping 4 s...\n[5.0005] 3: DONE\n[5.0005] 1: DONE\n[5.0007] 5: Start sleeping 5 s...\n[5.0008] 6: Start sleeping 1 s...\n[6.0020] 6: DONE\n[6.0022] 7: Start sleeping 4 s...\n[8.0016] 4: DONE\n[8.0018] 8: Start sleeping 1 s...\n[9.0023] 8: DONE\n[9.0025] 9: Start sleeping 5 s...\n[10.0014] 5: DONE\n[10.0015] 10: Start sleeping 2 s...\n[10.0026] 7: DONE\n[12.0017] 10: DONE\n[14.0036] 9: DONE\n```\n\nВыполнение 10 задач в 3 параллельных потоках PHP с НЕ буферизированным каналом:\n```php\n// Создаем исполнитель c 3-я отдельными параллельными потоками PHP и НЕ буферизированным каналом\n$executor = new \\App\\ParallelExecutor(3, 'taskChannel', 0);\n\n$i = 0;\n$startTime = microtime(true);\nwhile ($i < 10) {\n $i++;\n printf(\"[%.4f] execute\" . PHP_EOL, microtime(true) - $startTime, $i);\n $executor->execute(\n function ($i) use ($startTime) {\n $sleep = random_int(1, 5);\n printf(\"[%.4f] %2d: Start sleeping {$sleep} s...\" . PHP_EOL, microtime(true) - $startTime, $i);\n sleep($sleep);\n printf(\"[%.4f] %2d: DONE\" . PHP_EOL, microtime(true) - $startTime, $i);\n },\n [ $i ]\n );\n}\n```\n\nРезультат:\n```\n[0.0000] execute\n[0.0002] 1: Start sleeping 2 s...\n[0.0002] execute\n[0.0003] 2: Start sleeping 3 s...\n[0.0004] execute\n[0.0005] 3: Start sleeping 4 s...\n[0.0005] execute\n[2.0008] 1: DONE\n[2.0009] 4: Start sleeping 5 s...\n[2.0010] execute\n[3.0006] 2: DONE\n[3.0007] 5: Start sleeping 2 s...\n[3.0007] execute\n[4.0007] 3: DONE\n[4.0009] 6: Start sleeping 3 s...\n[4.0010] execute\n[5.0012] 5: DONE\n[5.0013] 7: Start sleeping 5 s...\n[5.0014] execute\n[7.0013] 4: DONE\n[7.0013] 6: DONE\n[7.0015] 8: Start sleeping 5 s...\n[7.0015] execute\n[7.0018] 9: Start sleeping 1 s...\n[7.0018] execute\n[8.0020] 9: DONE\n[8.0022] 10: Start sleeping 4 s...\n[10.0017] 7: DONE\n[12.0025] 10: DONE\n[12.0025] 8: DONE\n```\n\n\n## Автор\n© 2020 andrey-tech\n\n\n## Лицензия\nДанный код распространяется на условиях лицензии MIT.\n","has_starred","hub_user","immutable_tags_settings",{"_71":11,"_72":73},"enabled","rules",[74],".*","is_automated","permissions",{"_78":17,"_79":11,"_80":11},"read","write","admin","user","storage_size",153267697,"orgData","recentTags",[87],{"_88":40,"_89":90,"_91":92,"_93":94,"_95":96,"_46":114,"_115":90,"_116":29,"_117":52,"_53":118,"_119":120,"_121":105,"_122":114,"_123":62,"_124":17},"content_type","creator",10418270,"full_size",153252848,"id",112163526,"images",[97],{"_98":99,"_100":101,"_102":103,"_104":105,"_106":107,"_108":109,"_110":103,"_111":-5,"_112":92,"_59":62,"_113":-5},"architecture","amd64","digest","sha256:1d8e4d1d0b19c71cbf069e94ee66c8f4989e9764dd4d1073e6cd7923d188f44a","features","","last_pulled","2026-09-22T14:42:34.397752386Z","last_pushed","2020-08-06T10:40:46Z","os","linux","os_features","os_version","size","variant","2020-08-06T10:40:45.327083Z","last_updater","last_updater_username","media_type","latest","repository",9588255,"tag_last_pulled","tag_last_pushed","tag_status","v2","sbxKitMetadata","isPotentialSpam","isHubSbxKitsEnabled","showSbxLogoOverride","sbxTrademarkText","displaySecurityMetadata","tagAttestations","tagsHaveAttestations",[],"routes/_layout.r.$namespace.$reponame.tags",{"_34":136,"_143":144,"_132":153,"_154":11},{"_36":137,"_38":138,"_41":42,"_43":44,"_45":11,"_46":47,"_48":49,"_50":139,"_53":31,"_28":29,"_54":55,"_56":40,"_57":58,"_59":60,"_61":62,"_63":-5,"_64":58,"_65":66,"_67":11,"_68":29,"_69":140,"_75":11,"_76":142,"_81":29,"_82":83},[],[40],[52],{"_71":11,"_72":141},[74],{"_78":17,"_79":11,"_80":11},"tags",{"_145":60,"_146":-5,"_147":-5,"_148":149},"count","next","previous","results",[150],{"_88":40,"_89":90,"_91":92,"_93":94,"_95":151,"_46":114,"_115":90,"_116":29,"_117":52,"_53":118,"_119":120,"_121":105,"_122":114,"_123":62,"_124":17},[152],{"_98":99,"_100":101,"_102":103,"_104":105,"_106":107,"_108":109,"_110":103,"_111":-5,"_112":92,"_59":62,"_113":-5},[],"canDeleteTags","actionData","errors"]

andreytech/parallel-executor-php-example

Tags for andreytech/parallel-executor-php-example