pthread小测试

<?php
class My extends Thread
{
    public
        $array = array(‘default val 1‘, ‘default val 2‘),
        $msg = ‘default‘,
        $stop = false;

    public function run()
    {
        while(true)
        {
            echo $this->msg . PHP_EOL;
            if(count($this->array) > 0){
                foreach($this->array as $val){
                    var_dump($val);
                }
                $this->array = array();
            }
            /** cause this thread to wait **/
            $this->synchronized(
                function($thread){
                    if(count($this->array) < 1){
                        $thread->wait();
                    }
                },
                $this
            );
            echo PHP_EOL;
            if($this->stop){
                break;
            }
        } // while
    }
}
$my = new My();
$my->start();

sleep(1); // wait a bit

// test 1 - $thread->array[] = 1;
$my->synchronized(
    function($thread){
        $thread->msg = ‘test 1‘;
        $thread->array[] = 1;
        $thread->notify();
    },
    $my
);

sleep(1); // wait a bit

// test 2 - array_push($thread->array, 2);
$my->synchronized(
    function($thread){
        $thread->msg = ‘test 2‘;
        array_push($thread->array, 2);
        $thread->notify();
    },
    $my
);

sleep(1); // wait a bit

// test 3 - array_merge($thread->array, 3);
$my->synchronized(
    function($thread){
        $thread->msg = ‘test 3‘;
        $new = array(3);
        $thread->array = array_merge($thread->array, $new);
        $thread->notify();
    },
    $my
);

sleep(1); // wait a bit

$my->stop = true;
?>
out:
default
string(13) "default val 1"
string(13) "default val 2"

test 1

test 2

test 3
int(3)

so in this case only array_merge() worked.

<?php
class test extends thread{
    public $arr = array(1,2,3,4);

    public function run()
    {
        var_dump($this->arr->pop());
        var_dump($this->arr->shift());
        var_dump($this->arr);
        
        //常规方法
        var_dump(array_pop($this->arr));
        var_dump(array_shift($this->arr));
    }

}

$a = new test();

$a->start();

?>

输出结果：
int(4)
int(1)
object(Volatile)#2 (2) {
  [1]=>
  int(2)
  [2]=>
  int(3)
}
PHP Warning:  array_pop() expects parameter 1 to be array, object given in D:\Apache24\htdocs\threadtest.php on line 161 NULL
PHP Warning:  array_shift() expects parameter 1 to be array, object given in D:\Apache24\htdocs\threadtest.php on line 162 NULL