example MultiThreading

composer.json

@@ -14,6 +14,7 @@
         "doctrine/orm": "^2.8",
         "phpdocumentor/reflection-docblock": "^5.2",
         "sensio/framework-extra-bundle": "^5.1",
+        "sidorkinalex/multiphp": "dev-master",
         "symfony/asset": "5.2.*",
         "symfony/console": "5.2.*",
         "symfony/dotenv": "5.2.*",

src/Command/CustomCommand.php

@@ -0,0 +1,37 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: alex
+ * Date: 26.04.21
+ * Time: 9:23
+ */
+namespace App\Command;
+
+use App\Service\CThread;
+use Symfony\Component\Console\Command\Command;
+use Symfony\Component\Console\Input\InputArgument;
+use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Output\OutputInterface;
+
+class CustomCommand extends Command{
+    protected $projectDir;
+    protected static $defaultName="app:ThreadStart";
+    public function __construct($projectDir)
+    {
+        $this->projectDir = $projectDir;
+        parent::__construct();
+    }
+
+    protected function configure()
+    {
+        $this->setDescription("test command")
+            ->addArgument("keyThread",InputArgument::OPTIONAL,"test description string","");
+    }
+
+    protected function execute(InputInterface $input, OutputInterface $output)
+    {
+
+        $key=$input->getArgument('keyThread');
+        CThread::shell_start($key);
+    }
+}

src/Controller/Resume.php

@@ -7,10 +7,8 @@
  */
 namespace App\Controller;
 
-use App\DDD\Actions\AddToRecognitionList;
-use App\Service\DriverWorkerTomita;
-use App\Service\RecognitionList;
-use App\Service\Validator;
+
+use App\Service\CThread;
 use Redis;
 use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
 use Symfony\Component\HttpFoundation\Response;
@@ -28,7 +26,29 @@ class Resume extends AbstractController
      */
     public function testpars(): Response
     {
-        dd('lksajdfl');
+        $paramsFromThread = 3;
+        $test = new CThread($paramsFromThread,function ($n){
+            for ($i = 0; $i<$n; $i++){
+                $pid=getmypid();
+                file_put_contents('test1.log', $i." my pid is {$pid} \n", FILE_APPEND);
+                sleep(3);
+            }
+            return 'test1';
+        });
+        $test->start();
+
+        $test2 = new CThread($paramsFromThread,function ($n){
+            for ($i = 0; $i<$n; $i++){
+                $pid=getmypid();
+                file_put_contents('test2.log', $i." my pid is {$pid} \n", FILE_APPEND);
+                sleep(3);
+            }
+            return 'test2';
+        });
+        $test2->start();
+        $result1 = $test->getCyclicalResult();
+        $result2 = $test2->getCyclicalResult();
+        dd([$result1,$result2]);
         return new Response("sadfasdf");
     }
 }

src/Service/CThread.php

@@ -0,0 +1,23 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: alex
+ * Date: 14.05.21
+ * Time: 12:52
+ */
+
+namespace App\Service;
+
+
+use SidorkinAlex\Multiphp\Thread;
+
+class CThread extends Thread
+{
+    //public static $php_worker_path=!empty($_SERVER['OLDPWD']) ? $_SERVER['OLDPWD'] :;
+    public function __construct($params = null, $function)
+    {
+        parent::__construct($params, $function);
+        $cor=!empty($_SERVER['OLDPWD']) ? $_SERVER['OLDPWD'] : $_SERVER['DOCUMENT_ROOT'];
+        self::$php_worker_path = $cor."/bin/console app:ThreadStart";
+    }
+}