PTHREADS SYMFONY Klassen und Konstante in run() -Funktion der Klasse erweitern \ Thread

Question

Ich habe ziemlich viel über die Verwendung von Pthreads mit symfony.

Mein Problem ist irgendwie ähnlich, was in dieser Frage ausgesetzt ist: Multi-threading in Symfony2.

Kurz gesagt: Mein Back-End erreicht eine Zeitüberschreitung, bevor alle Daten verarbeitet werden, die es verarbeiten soll, und dann kann es keine Antwort an mein Frontend zurücksenden.

Daher scheint der Versuch, verschiedene Threads zu verwenden, (eine der) Lösung (en) zu sein, dieses Problem zu umgehen (bis zu einer gewissen Grenze, ich bin mir dessen bewusst).

Durch das Lesen, ich habe über die Grundlagen herausgefunden, wie pThreads gearbeitet und fand diesen Artikel sehr relevant darüber: https://blog.madewithlove.be/post/thread-carefully/

ich mit einem grundlegenden symfony Projekt ein Musterkoffer kam es zu verstehen:

Die Hauptsteuerklasse unter [my_symf_project] \ src \ AppBundle \ Controller:

class DefaultController extends Controller 
{ 
    /** 
    * @Route("/", name="homepage") 
    */ 
    public function indexAction(Request $request) 
    { 
     // replace this example code with whatever you need 
     $tt = new TestThread('BOOOMSTICK'); 
     $tt->start(); 

     return $this->render('default/index.html.twig', [ 
      'base_dir' => realpath($this->getParameter('kernel.root_dir').'/..'), 
     ]); 
    } 
} 

Die Klasse erstreckenden Faden unter: [my_symf_project] \ src \ AppBundle \ Dependency Injection:

<?php 
namespace AppBundle\DependencyInjection; 

    class TestThread extends \Thread { 
     public function __construct($text){ 
      $this->text = $text; 
     } 

     public function run(){ 
      $vendorAutoload= __DIR__.'/../../../vendor/autoload.php'; 
      require_once $vendorAutoload; 
      require_once __DIR__.'/ClassOutsideThread.php'; 

      $cot = new ClassOutsideThread(' RUN ' . ' ' . $this->text); 
      $cot->show(); 
     } 

    } 
    ?> 

Und eine andere Klasse (außerhalb der Klasse Verlängerung der Thread) als auch unter [my_symf_project] \ src \ AppBundle \ Dependency Injection:

<?php 
namespace AppBundle\DependencyInjection; 

class ClassOutsideThread { 
    public function __construct($text){ 
     $this->text = $text; 
    } 

    public function show(){ 
     echo $this->text; 
    } 
} 
?> 

Thru den Code oben schaffe ich 'RUN BOOOMSTICK' auf anzuzeigen die Oberseite der Standard symfony leeren Projektseite. Und ich habe verstanden, dass das möglich ist, weil ich die Aussage "require_once __DIR __. '/ ClassOutsideThread.php';" am Anfang der Funktion run().

Jetzt bin ich mit einigen Fragen darüber, wie an childthreads übergeben: Klassen und andere symfony Kontextparameter, durch die Funktion run(). Hier ist eine Wunschliste von dem, was ich zu bekommen versuchen:

1. Klassen-Dateien unter dem Ordner [my_symf_proj] \ src \ AppBundle: Gibt es eine schnelle Möglichkeit, unter diesem Bündel all Klassen zu laden, wie die Autoload über die 'Vendor' Ordner, der in meiner Klasse TestThread verwendet wird (aus: Boostraping symfony 2 for pthread from command)?
2. Ich möchte Symfony Logger in der Funktion run() verwenden. Ich habe versucht: $ GLOBALS ['Kernel'] -> getContainer() -> Get ('Logger'), aber ich bekomme eine große Lücke in der [my_symf_proj] \ var \ logs \ dev.log, also frage ich mich wie Zugriff auf $ GLOBALS ['kernel'] -> getContainer() durch einen Childthread?
3. Ich möchte meine Doctrine-Verbindung mit dem DB (der, der den Symfony-Parametern entspricht) in der Funktion run() verwenden. Wie kann ich das machen? (Wie auch ich habe $ GLOBALS versucht [ 'Kernel'] -> getContainer() -> get ('dbal.connection'), aber es scheint nicht zu funktionieren.)

PS: Ich bin Beachten Sie, dass die Verwendung von $ GLOBALS ['kernel'] -> getContainer() keine Symfony Best Practice ist, auch in dieser speziellen Childthreads-Situation, es scheint eine bequeme Option zu sein.

Answer 1

Durch die Hinweise, die zur Verfügung gestellt wurden, schaffe ich es, es zur Arbeit zu bringen. . Hier ist ein Beispiel eines Fadens in symfony 3.0 *

Ersetzen Sie die Klasse TestThread die durch die folgende man in der Frage ist, und Sie werden sehen, dass der symfony Zusammenhang mit dem childthread bekommt:

 class TestThread extends \Thread { 
     public function __construct($text){ 


       $this->text = $text; 
      $this->kernelName = $GLOBALS['kernel']->getName(); 
      $this->kernelEnv = $GLOBALS['kernel']->getEnvironment(); 
      $this->kernelDebug = $GLOBALS['kernel']->isDebug(); 

     } 

     public function run(){ 
      require_once __DIR__.'/../../../app/autoload.php'; 
      require_once __DIR__.'/../../../app/AppKernel.php'; 



      $kernelInThread = new \AppKernel($this->kernelEnv, $this->kernelDebug); 
      $kernelInThread->loadClassCache(); 
      $kernelInThread->boot(); 


      $container = $kernelInThread->getContainer(); 


      $log = $container->get('logger'); 

      $log->info('THIS IS WORKING NOW'); 

      $con = $container->get('doctrine.dbal.default_connection'); 
      $q = new PdoQuery($con); 
       $c = $q->getConnection()->prepare('select field from table'); 

      $c->execute(); 
      $res = $c->fetchAll(); 
      var_dump($res); 



      echo 'the end </br>'; 
     } 
    } 

Answer 2

Geben Sie einen Blick auf this post

1 Sie so etwas wie

$loader = require __DIR__.'/../../../../../../vendor/autoload.php'; 

2-3 verwenden Wenn Sie Objekte zwischen Thread nicht teilen müssen Sie einfach in Ihrem run-Methode tun können:

$kernel = new \AppKernel($this->env, $this->debug); 
$kernel->loadClassCache(); 
$kernel->boot(); 
$this->container = $kernel->getContainer(); 
$this->container->get('doctrine_mongodb'); 
.....