pthreads v3下一些坑和须要注意的地方

1、子线程没法访问父线程的全局变量，但父线程能够访问子线程的变量

<?php

class Task extends Thread
{
    public $data;

    public function run()
    {
        global $num;
        var_dump($num);
        $this->data = 'abc';

        //这是打印null
        var_dump($GLOBALS);
        $GLOBALS['test'] = 'def';
    }
}

//主线程中的全局变量，子线程中是没法访问的
//php中建立子线程，它会有一个单独的堆，运行在单独的地址空间中
//并不能像有些语言中，子线程是能够访问的到主线程中的变量的。
$num = 666;

$GLOBALS['test'] = 'test';

$t = new Task();
$t->start() && $t->join();

//主线程能够访问子线程的变量
var_dump($t->data);

结果以下：

 

2、子线程没法修改父线程的变量

<?php

class Task extends Thread
{
    private $data;

    public function __construct(&$data)
    {
        $this->data = $data;
    }

    public function run()
    {
        echo "task data : ", $this->data, "\n";
        $this->data = 'def';
        echo "task data : ", $this->data, "\n";
    }
}

$data = 'abc';

//咱们这里传入的是引用
$t = new Task($data);
$t->start() && $t->join();

//可是$data变量数据并没改变
//这说明咱们经过构造函数传入Task对象中的$data只是一个拷贝
//子线程中并不可以操做主线程中的变量
var_dump($data);

结果以下：

 

3、pthreads v3版本能够设置成员为匿名函数

<?php

class Task extends Thread
{
    private $call;


    public function __construct()
    {
        //pthreads v3版本好像能够设置成员为匿名函数
        //在v2版本中好像是不能够的
        $this->call = function ($param1, $param2) {
            echo "task call param1 : {$param1} param2 : {$param2}\n";
        };
    }

    public function run()
    {
        //直接调用成员匿名函数
        ($this->call)("hello", "world");
    }
}

$t = new Task();
$t->start() && $t->join();

结果以下：

 

4、对于数据库链接资源，咱们须要声明为静态成员

<?php

class Task extends Thread
{
    private $db;

    public function __construct()
    {
        //注意这里会报错，不能对PDO实例进行序列化或反序列化
        $this->db = new PDO('mysql:dbname=test;host=192.168.33.226', 'root', '');
    }

    public function run()
    {
        $result = $this->db->query("select id,name from tb_user");
        while ($row = $result->fetch(PDO::FETCH_ASSOC)) {
            echo "{$row['id']}\t{$row['name']}\n";
        }
    }
}

$t = new Task();
$t->start() && $t->join();

结果以下：

代码修改以下：

<?php

class Task extends Thread
{
    //咱们须要把数据库链接资源，声明为静态成员，而后调用静态方法进行建立
    private static $db;

    //咱们直接在__construct()构造函数里对$db进行实例化，好像会是null，有兴趣的能够试试
    public static function getConn()
    {
        if (!is_resource(self::$db)) {
            self::$db = new PDO('mysql:dbname=test;host=192.168.33.226', 'root', '');
        }
        return self::$db;
    }

    public function run()
    {
        $result = self::getConn()->query("select id,name from tb_user");
        while ($row = $result->fetch(PDO::FETCH_ASSOC)) {
            echo "{$row['id']}\t{$row['name']}\n";
        }
    }
}

$t = new Task();
$t->start() && $t->join();

结果以下：

 

最后说明，不排除pthreads之后的版本升级上面的有些问题不会出现。

个人php版本是7.2.4，pthreads的版本是3.1.7dev