windows php 多线程

大家可以先 打开phpinfo() 看看 自己的php信息

主要看的有







在windows 中使用pthreads拓展必须是ts版本的php也就是线程安全版本的php

大家打开http://windows.php.net/downloads/pecl/releases/pthreads

我选择的的pthread版本是2.0.9

根据我的php信息

我选择的包是

将 php_pthreads.dll 复制到php程序中 'bin\php\ext\' 这个目录中
将 pthreadVC2.dll复制到php程序中 'bin\php\'这个目录中
将 pthreadVC2.dll复制到 'C:\windows\system32' 这个目录中

打开php程序中 php\php.ini 加入

extension=php_pthreads.dll

我用的是phpstrom

进行php程序路径的配置

写一个测试脚本

<?php

class MyThread extends Thread {
public $res    = '';
public $url    = array();
public $name   = '';
public $runing = false;
public $lc     = false;

public function __construct($name) {
$this->res    = '暂无,第一次运行.';
$this->param    = 0;
$this->lurl   = 0;
$this->name   = $name;
$this->runing = true;
$this->lc     = false;
}

public function run() {
while ($this->runing) {

if ($this->param != 0) {
$nt          = rand(1, 10);
echo "线程[{$this->name}]收到任务参数::{$this->param},需要{$nt}秒处理数据.\n";
$this->res   = rand(100, 999);
sleep($nt);
$this->lurl = $this->param;
$this->param   = '';
} else {
echo "线程[{$this->name}]等待任务..\n";
}
sleep(1);
}
}

}

//这里创建线程池.
$pool[] = new MyThread('a');
$pool[] = new MyThread('b');
$pool[] = new MyThread('c');

//启动所有线程,使其处于工作状态
foreach ($pool as $w) {
$w->start();
}

//派发任务给线程
for ($i = 1; $i < 10; $i++) {
$worker_content = rand(10, 99);
while (true) {
foreach ($pool as $worker) {
//参数为空则说明线程空闲
if (!$worker->param) {
$worker->param = $worker_content;
echo "[{$worker->name}]线程空闲,放入参数{$worker_content},上次参数[{$worker->lurl}]结果[{$worker->res}].\n";
break 2;
}
}
sleep(1);
}
}
echo "所有线程派发完毕,等待执行完成.\n";

//等待所有线程运行结束
while (count($pool)) {
//遍历检查线程组运行结束
foreach ($pool as $key => $threads) {
if ($threads->param=='') {
echo "[{$threads->name}]线程空闲,上次参数[{$threads->lurl}]结果[{$threads->res}].\n";
echo "[{$threads->name}]线程运行完成,退出.\n";
//设置结束标志
$threads->runing = false;
unset($pool[$key]);
}
}
echo "等待中...\n";
sleep(1);
}
echo "所有线程执行完毕.\n";

运行结果

D:\phpStudy\php\php-5.5.38\php.exe D:\WWW\PHP\webapp\test\thread.php

线程[a]等待任务..

线程[b]等待任务..

线程[c]等待任务..

[a]线程空闲,放入参数74,上次参数[0]结果[暂无,第一次运行.].

[b]线程空闲,放入参数32,上次参数[0]结果[暂无,第一次运行.].

[c]线程空闲,放入参数73,上次参数[0]结果[暂无,第一次运行.].

线程[a]收到任务参数::74,需要9秒处理数据.

线程[b]收到任务参数::32,需要4秒处理数据.

线程[c]收到任务参数::73,需要8秒处理数据.

[b]线程空闲,放入参数34,上次参数[32]结果[855].

线程[b]收到任务参数::34,需要4秒处理数据.

[c]线程空闲,放入参数84,上次参数[73]结果[205].

线程[c]收到任务参数::84,需要7秒处理数据.

[a]线程空闲,放入参数20,上次参数[74]结果[657].

[b]线程空闲,放入参数78,上次参数[34]结果[523].

线程[a]收到任务参数::20,需要1秒处理数据.

线程[b]收到任务参数::78,需要7秒处理数据.

[a]线程空闲,放入参数99,上次参数[20]结果[609].

线程[a]收到任务参数::99,需要10秒处理数据.

[c]线程空闲,放入参数95,上次参数[84]结果[689].

所有线程派发完毕,等待执行完成.

等待中…

线程[c]收到任务参数::95,需要7秒处理数据.

[b]线程空闲,上次参数[78]结果[639].

[b]线程运行完成,退出.

等待中…

等待中…

等待中…

等待中…

[a]线程空闲,上次参数[99]结果[340].

[a]线程运行完成,退出.

等待中…

等待中…

[c]线程空闲,上次参数[95]结果[317].

[c]线程运行完成,退出.

等待中…

所有线程执行完毕.

Process finished with exit code 0

三个线程处理十个任务的测试脚本