PHP pthreads v3使用中的一些坑和注意点分析

本文实例讲述了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. public function __construct()
8. {
9. //pthreads v3版本好像可以设置成员为匿名函数
10. //在v2版本中好像是不可以的
11. $this->call = function ($param1, $param2) {
12. echo "task call param1 : {$param1} param2 : {$param2}\n";
13. };
14. }
15.  
16. public function run()
17. {
18. //直接调用成员匿名函数
19. ($this->call)("hello", "world");
20. }
21. }
22.  
23. $t = new Task();
24. $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

希望本文所述对大家PHP程序设计有所帮助。

原文链接：https://www.cnblogs.com/jkko123/p/8919013.html