Мне нужна небольшая помощь с pthreads в php. у меня следующий класс
namespace le\Thread;
class Thread extends \Thread
{
protected $method;
protected $params;
protected $result = null;
protected $joined = false;
/**
* Provide a passthrough to call_user_func_array
**/
public function __construct($method, $params)
{
$this->method = $method;
$this->params = $params;
}
/**
* The smallest thread in the world
**/
public function run()
{
if (($this->result = call_user_func_array($this->method, $this->params))) {
return true;
} else {
return false;
}
}
/**
* Static method to create your threads from functions ...
**/
public static function process($method, $params)
{
$thread = new self($method, $params);
if ($thread->start()) {
return $thread;
}
/** else throw Nastyness **/
}
/**
* Do whatever, result stored in $this->result, don't try to join twice
**/
public function getResult()
{
if (!$this->joined) {
$this->joined = true;
$this->join();
}
return $this->result;
}
}
и я хочу использовать его таким образом. В другом классе у меня есть тяжелый метод ЦП, который я хочу обрабатывать многопоточно.
$thread = Thread::process([$this, 'method'], $dataArray);
$thread->getResult();
но выдает следующую ошибку
Serialization of 'Closure' is not allowed
Как я могу это исправить? Это вообще возможно?
