PHP多线程编程和非阻塞实现方法

PHP多线程

---

线程概述

线程是操作系统能够进行调度的最小单位

• 一个多线程程序比单线程程序被操作系统调度的概率更大，所以多线程程序一般会比单线程程序更高效；
• 多线程程序的多个线程可以在多核 CPU 的多个核心同时运行，可以将完全发挥机器多核的优势；
• 线程的创建和切换的系统开销都比进程要小，所以一定程度上会比多进程更高效；
• 线程天生的共享内存空间，线程间的通信更简单，避免了进程IPC引入新的复杂度。

什么时候该使用线程

• I/O 阻塞会使操作系统发生任务调度，阻塞当前任务，所以代码中 I/O 多的情况下，使用多线程时可以将代码并行
• 多线程能充分利用 CPU，所以有多处大计算量代码时，也可以使用多线程使他们并行执行

用线程的好与坏

• PHP 实现的线程安全主要是使用 TSRM 机制对 全局变量和静态变量进行了隔离，将全局变量和静态变量 给每个线程都复制了一份，各线程使用的都是主线程的一个备份，从而避免了变量冲突，也就不会出现线程安全问题。
• 子线程一旦开始运行，主线程便无法再对子线程运行细节进行调整

扩展安装

PHP 默认并不支持多线程，要使用多线程需要安装 pthread 扩展，而要安装 pthread 扩展，必须使用 --enable-maintainer-zts 参数重新编译 PHP，这个参数是指定编译 PHP 时使用线程安全方式。

./configure --enable-maintainer-zts --with-tsrm-pthreads

实例

class Request extends Thread {
    public $url;
    public $response;
    public function __construct($url) {
        $this->url = $url;
    }
    public function run() {
        $this->response = file_get_contents($this->url);
    }
}
$chG = new Request("www.google.com");
$chB = new Request("www.baidu.com");
$chG ->start();
$chB ->start();
$chG->join();
$chB->join();

$gl = $chG->response;
$bd = $chB->response;

PHP非阻塞

• 使用 fastcgi_finish_request()

echo "program start...";
fastcgi_finish_request();

sleep(1);
echo 'debug1...';

sleep(10);
echo 'debug2...';

• 使用 fsockopen()
  stream_set_blocking()

• 使用 cURL
  $cmh = curl_multi_init();

• 使用 Gearman/Swoole 扩展

• 使用缓存和队列
  redis

• 调用系统命令
  $cmd = 'nohup php ./processd.php $someVar >/dev/null &';

• 使用 pcntl_fork()

• PHP 原生支持
  yield