Symfony 学说实体管理器注入线程

Question

我正在尝试在线程中使用学说实体管理器。我按照建议使用静态范围 here 。 A 类是一个 symfony 服务，并且在 service.yml 中注入了学说实体管理器

class A extends \Thread{
static $em;
public function __construct($em)
    {
    self::$em = $em;
    }
    public function run(){
       self::$em->doSomething(); //here em is null
    }
}

如何从线程中正确使用实体管理器？

更新： 正如@Mjh 建议的那样，我无法从线程共享实体管理器。但是，我可以在每个线程中都有一个 em，但这非常低效。 一个解决方案可以是构建一个在线程之间共享的容器线程类，我将在其中存储从学说查询返回的实体。实体显然会与实体管理器分离，但我只需要线程之间共享的读取缓存。

更新2： 看我的第一个答案 未解决的问题：避免为每个线程初始化一个新环境

Answer 1

我们已经建立了一个在线程之间共享的原则缓存，扩展了一个线程安全堆栈。 警告部分代码是为了演示目的而被简化的。

class work extends \Collectable{
   protected $parameters;
   public static $doctrine_mongodb;
   public function __construct($parameters){
      $this->parameters           = $parameters;
   }
   public function run()
   {
      try{
          $loader = require __DIR__.'/../../../../../../vendor/autoload.php';
          static::$container = unserialize($this->worker->container);
          static::$doctrine_mongodb     = static::$container->get('doctrine_mongodb');
        ...
        DO WORK
        $dm     = static::$doctrine_mongodb->getManager();
        $repo   = $dm->getRepository('Bundle:Document');
        $ris    = $this->worker->doctrinecache->FindOneBy($repo, array('key' => $val));
        ...
      }catch(\Exception $e){}
   }
}

注意：在工作类中，我们有工作代码的并行执行，在那里我们可以安全地使用学说公共缓存。 共享实体管理器不一样，因为文档是分离的，但用于阅读目的是好的。如果有人需要管理实体，可以使用合并原则的方法。

   class SWorker extends \Worker{
      public $env;
      public $debug; 
      public $mongodb_cache_engine;
      public function __construct( $env, $debug, $doctrinecache, $workParams){    
         $this->workParams            = $work;    
         $this->env                   = $env; 
         $this->debug                 = $debug;
         $this->doctrinecache         = $doctrinecache  ; 
      }

      public function start($options = null){
         return parent::start(PTHREADS_INHERIT_NONE);
      }

      public function run(){
         require_once __DIR__.'/../../../../../../app/bootstrap.php.cache';
         require_once __DIR__.'/../../../../../../app/AppKernel.php';
         $kernel = new \AppKernel($this->env, $this->debug);
         $kernel->loadClassCache();
         $kernel->boot();
         $this->container = serialize($kernel->getContainer());   
      }
   }

在 Sworker 类中，我们为线程准备 symfony 环境。为此，请转至 svenpelster https://github.com/krakjoe/pthreads/issues/369。

class doctrinecache  extends \Stackable{
   public function __call($MethodName, $arguments){

      $repository = array_shift($arguments);
      $documentName = $repository->getDocumentName();    
      $hash = $this->generateHash($MethodName, $documentName, $arguments);
      return $this->cacheIO($hash, $repository, $MethodName, $arguments);
   }  
   public function cacheIO($hash, $repository, $MethodName, $arguments){
       $result = isset($this["{$hash}"])? $this["{$hash}"] : NULL;
       if(!$result){
          $result = call_user_func_array(array($repository, $MethodName), $arguments); 
          $this["{$hash}"] =  $result;
       }                    
       return $result;
    }
}

最后

$doctrineCache = $this->kernel->get('doctrineCacheService');
$pool = new \Pool($workerNumber, SWorker::class, [$this->kernel->getEnvironment(), $this->kernel->isDebug(), $doctrineCache  ,$workParams]);    
while(current($works ))
{
     $pool->submit(current($works ));
     next($works);
}

$pool->shutdown();

while(current($works ))
{
     $arrayResults[] = current($works )->getResults();
     next($works);
}