PHP 性能优化：生成器 yield 的初体验

public function handle()
    {
        app('log')->info('----粉丝通知--这里是发送通知队列-----');

        //获取这个用户的所有粉丝
        $users = $this->getFollowUser();

        foreach ($users as $v){
            //发送微信通知
            $v->fromUser->notify(new NewThread($this->actor,$this->thread));
        }
        app('log')->info('----粉丝通知--发送完成-----');

        $this->delete();
    }

public function getFollowUser()
{
    $limit=100;
    $id=0;
    do{
        $follow = UserFollow::query()
            ->where('to_user_id',$this->thread->user_id)
            ->where('id','>',$id)
            ->with('fromUser')
            ->limit($limit)
            ->orderBy('id')
            ->get();
        foreach ($follow as $v){
            $id=$v->id;
            yield $v;
        }
    }while(count($follow)==$limit);
}Copy

public function handle()
    {
        app('log')->info('----粉丝通知--这里是发送通知队列-----');

        //获取这个用户的所有粉丝
        $limit=100;
        $id=0;
        do{
            $follow = UserFollow::query()
                ->where('to_user_id',$this->thread->user_id)
                ->where('id','>',$id)
                ->with('fromUser')
                ->limit($limit)
                ->orderBy('id')
                ->get();
            foreach ($follow as $v){
                $id=$v->id;
                //发送微信通知
                $v->fromUser->notify(new NewThread($this->actor,$this->thread));
            }
        }while(count($follow)==$limit);
        app('log')->info('----粉丝通知--发送完成-----');

        $this->delete();
    }Copy

$follow = UserFollow::query()
            ->where('to_user_id',$this->thread->user_id)
            ->with('fromUser')
            ->get();Copy

UserFollow::query()
    ->where('to_user_id',$this->thread->user_id)
    ->with('fromUser')
    ->cursor()
    ->each(function($v) {
        $v->fromUser->notify(new NewThread($this->actor,$this->thread));
    });Copy

<?php

class Db{
    public $dbh;

    public function __construct()
    {
        $this->dbh = new PDO('mysql:host=127.0.0.1;port=3306;dbname=test', 'root', '',
            [
                PDO::ATTR_CASE => PDO::CASE_NATURAL,
                PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
                PDO::ATTR_ORACLE_NULLS => PDO::NULL_NATURAL,
                PDO::ATTR_STRINGIFY_FETCHES => false,
                PDO::ATTR_EMULATE_PREPARES => true,
            ]);

    }

    public function fetch()
    {
        $sth = $this->dbh->prepare("select * from `stored_events`");

        $sth->setFetchMode(PDO::FETCH_OBJ);
        $sth->execute();

        while ($record = $sth->fetch()) {
            yield $record;
        }
    }
}

$db = new Db();

foreach ($db->fetch() as $v) {
    var_dump($v);
};
Copy