php多线程实例

太过爱你忘了你带给我的痛 2022-02-01 13:15 267阅读 0赞

转自–[https://www.cnblogs.com/webwei2017/articles/9149787.html][https_www.cnblogs.com_webwei2017_articles_9149787.html]

<?php
    class vote extends Thread {
        public $name  = '';
        public $param = '';
        public $p_res = '';//保存上次结果
        public $runing = true;
        public function __construct($name) {
            $this->name  = $name;
        }
        public function run() {
            while ($this->runing) {
                if ($this->param != '') {
                    $nt     = rand(1, 10);
                    echo "线程[{$this->name}]收到任务参数::{$this->param},需要{$nt}秒处理数据.\n";
                    $this->p_res = rand(100, 999);
                    sleep($nt);
                    $this->param  = '';
                } else {
                    echo "线程[{$this->name}]等待任务..\n";
                }
                sleep(1);
            }
        }
    }
    //这里创建线程池.
    $pool[] = new vote('a');
    $pool[] = new vote('b');
    $pool[] = new vote('c');
    //启动所有线程,使其处于工作状态
    foreach ($pool as $w) {
        $w->start();
    }
    //派发任务给线程
    $result = [];
    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}.\n";
                    if(!empty($worker->p_res))
                        $result[] = $worker->p_res;
                    break 2;
                }
            }
            sleep(1);
        }
    }
    echo "所有线程派发完毕,等待执行完成.\n";
    //等待所有线程运行结束，资源回收
    while (count($pool)) {
        //遍历检查线程组运行结束
        foreach ($pool as $key => $threads) {
            if ($worker->param=='') {
                echo "[{$threads->name}]线程运行完成,退出.\n";
                $result[] = $threads->p_res;
                //设置结束标志
                $threads->runing = false;
                unset($pool[$key]);
            }
        }
        echo "等待中...\n";
        sleep(1);
    }
    echo "所有线程执行完毕.\n";
    var_dump($result);

[https_www.cnblogs.com_webwei2017_articles_9149787.html]: https://www.cnblogs.com/webwei2017/articles/9149787.html