本文实例讲述了PHP pthreads v3使用中的一些坑和注意点，分享给大家供大家参考，具体如下：

一、子线程无法访问父线程的全局变量，但父线程可以访问子线程的变量

1. <?php 
2.  
3. class Task extends Thread 
4. { 
5.   public $data; 
6.  
7.   public function run() 
8.   { 
9.     global $num; 
10.     var_dump($num); 
11.     $this->data = 'abc'; 
12.  
13.     //这是打印null 
14.     var_dump($GLOBALS); 
15.     $GLOBALS['test'] = 'def'; 
16.   } 
17. } 
18.  
19. //主线程中的全局变量，子线程中是无法访问的 
20. //php中创建子线程，它会有一个单独的堆，运行在单独的地址空间中 
21. //并不能像有些语言中，子线程是可以访问的到主线程中的变量的。 
22. $num = 666; 
23.  
24. $GLOBALS['test'] = 'test'; 
25.  
26. $t = new Task(); 
27. $t->start() && $t->join(); 
28.  
29. //主线程可以访问子线程的变量 
30. var_dump($t->data); 

结果如下：

二、子线程无法修改父线程的变量

1. <?php 
2.  
3. class Task extends Thread 
4. { 
5.   private $data; 
6.  
7.   public function __construct(&$data) 
8.   { 
9.     $this->data = $data; 
10.   } 
11.  
12.   public function run() 
13.   { 
14.     echo "task data : ", $this->data, "\n"; 
15.     $this->data = 'def'; 
16.     echo "task data : ", $this->data, "\n"; 
17.   } 
18. } 
19.  
20. $data = 'abc'; 
21.  
22. //我们这里传入的是引用 
23. $t = new Task($data); 
24. $t->start() && $t->join(); 
25.  
26. //但是$data变量数据并没改变 
27. //这说明我们通过构造函数传入Task对象中的$data只是一个拷贝 
28. //子线程中并不能够操作主线程中的变量 
29. var_dump($data); 

结果如下：

三、pthreads v3版本可以设置成员为匿名函数

1. <?php 
2.  
3. class Task extends Thread 
4. { 
5.   private $call; 
6.  
7.  
8.   public function __construct() 
9.   { 
10.     //pthreads v3版本好像可以设置成员为匿名函数 
11.     //在v2版本中好像是不可以的 
12.     $this->call = function ($param1, $param2) { 
13.       echo "task call param1 : {$param1} param2 : {$param2}\n"; 
14.     }; 
15.   } 
16.  
17.   public function run() 
18.   { 
19.     //直接调用成员匿名函数 
20.     ($this->call)("hello", "world"); 
21.   } 
22. } 
23.  
24. $t = new Task(); 
25. $t->start() && $t->join(); 

结果如下：

四、对于数据库连接资源，我们需要声明为静态成员

1. <?php 
2.  
3. class Task extends Thread 
4. { 
5.   private $db; 
6.  
7.   public function __construct() 
8.   { 
9.     //注意这里会报错，不能对PDO实例进行序列化或反序列化 
10.     $this->db = new PDO('mysql:dbname=test;host=192.168.33.226', 'root', ''); 
11.   } 
12.  
13.   public function run() 
14.   { 
15.     $result = $this->db->query("select id,name from tb_user"); 
16.     while ($row = $result->fetch(PDO::FETCH_ASSOC)) { 
17.       echo "{$row['id']}\t{$row['name']}\n"; 
18.     } 
19.   } 
20. } 
21.  
22. $t = new Task(); 
23. $t->start() && $t->join(); 

结果如下：

代码修改如下：

1. <?php 
2.  
3. class Task extends Thread 
4. { 
5.   //我们需要把数据库连接资源，声明为静态成员，然后调用静态方法进行创建 
6.   private static $db; 
7.  
8.   //我们直接在__construct()构造函数里对$db进行实例化，好像会是null，有兴趣的可以试试 
9.   public static function getConn() 
10.   { 
11.     if (!is_resource(self::$db)) { 
12.       self::$db = new PDO('mysql:dbname=test;host=192.168.33.226', 'root', ''); 
13.     } 
14.     return self::$db; 
15.   } 
16.  
17.   public function run() 
18.   { 
19.     $result = self::getConn()->query("select id,name from tb_user"); 
20.     while ($row = $result->fetch(PDO::FETCH_ASSOC)) { 
21.       echo "{$row['id']}\t{$row['name']}\n"; 
22.     } 
23.   } 
24. } 
25.  
26. $t = new Task(); 
27. $t->start() && $t->join(); 

结果如下：

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

我的php版本是7.2.4，pthreads的版本是3.1.7dev

Tags: pthreads

分享到：