任何不是从 pthreads 定义派生的对象都将在将其设置为从 pthreads 派生的对象的成员时被序列化。
+= 和 [] 等操作在内部使用指针，序列化与其他对象的指针不兼容。在介绍页面的手册中，它指出任何打算由多个上下文操作的对象都应该扩展 Stackable、Thread 或 Worker，例如
<?php
class Sum extends Stackable {
private $value = 0;
public function add($inc) { $this->value += $inc; }
public function getValue() { return $this->value; }
public function run(){}
}
class MyThread extends Thread {
public $sum;
public function __construct(Sum $sum) {
$this->sum = $sum;
}
public function run(){
for ($i=0; $i < 10; $i++) {
$this->sum->add(5);
echo $this->sum->getValue() . " ";
}
}
}
$sum = new Sum();
$thread = new MyThread($sum);
$thread->start();
$thread->join();
echo $sum->getValue();
?>
如果 Sum 不使用指针，您可以选择在连接后从线程对象中检索引用。
这些都是简单的操作，您不需要同步。您应该同步的唯一时间是您计划等待一个对象或通知一个对象。
与 pthread 捆绑的对象非常适合这种环境，并且永远不会被序列化。
请务必阅读手册中的介绍以及您希望使用的方法中的所有示例，以确切了解什么是什么，然后随时问为什么:)
我知道 PHP 的用户不习惯做研究，但我们在这里挑战极限，你会发现有正确的方法来做不正确的事情，其中大多数都记录在示例中，以及任何不是我肯定会在 SO 上从我身上提取出来，并最终找到它的文档方式。
我不确定您给出的示例是否特别测试了对象，但是您提供的代码不必是两个对象，也不应该是两个对象，请考虑以下内容：
<?php
class MyThread extends Thread {
public $sum;
public function run(){
for ($i=0; $i < 10; $i++) {
$this->add(5);
printf("%d ", $this->sum);
}
}
public function add($num) { $this->sum += $num; }
public function getValue() { return $this->sum; }
}
$thread = new MyThread();
$thread->start();
$thread->join();
var_dump($thread->getValue());
?>
查看更多功能并进行解释可能对您很有用，所以这里有一个与您类似的示例：
<?php
class MyThread extends Thread {
public $sum;
public function __construct() {
$this->sum = 0;
}
public function run(){
for ($i=0; $i < 10; $i++) {
$this->add(5);
$this->writeOut("[%d]: %d\n", $i, $this->sum);
}
$this->synchronized(function($thread){
$thread->writeOut("Sending notification to Process from %s #%lu ...\n", __CLASS__, $thread->getThreadId());
$thread->notify();
}, $this);
}
public function add($num) { $this->sum += $num; }
public function getValue() { return $this->sum; }
/* when two threads attempt to write standard output the output will be jumbled */
/* this is a good use of protecting a method so that
only one context can write stdout and you can make sense of the output */
protected function writeOut($format, $args = null) {
$args = func_get_args();
if ($args) {
vprintf(array_shift($args), $args);
}
}
}
$thread = new MyThread();
$thread->start();
/* so this is synchronization, rather than joining, which requires an actual join of the underlying thread */
/* you can wait for notification that the thread is done what you started it to do */
/* in these simple tests the time difference may not be apparent, but in real complex objects from */
/* contexts populated with more than 1 object having executed many instructions the difference may become very real */
$thread->synchronized(function($thread){
if ($thread->getValue()!=50) {
$thread->writeOut("Waiting for thread ...\n");
/* you should only ever wait _for_ something */
$thread->wait();
$thread->writeOut("Process recieved notification from Thread ...\n");
}
}, $thread);
var_dump($thread->getValue());
?>
这在一些简单的示例中结合了一些更高级的功能，并进行了评论以帮助您。在共享对象的主题上，如果 Thread 对象包含其他线程或堆栈所需的某些功能和数据，则传递它并没有错。您应该旨在使用尽可能少的线程和对象来完成工作。