一、Generator基础与协程概念

PHP Generator是实现协程的基础，通过yield实现中断执行：

function simpleGenerator() {
    echo "开始执行n";
    yield "第一次中断返回";
    echo "继续执行n";
    yield "第二次中断返回";
}

$gen = simpleGenerator();
foreach ($gen as $value) {
    echo "获取值: $valuen";
}
/* 输出：
开始执行
获取值: 第一次中断返回
继续执行
获取值: 第二次中断返回
*/

二、协程任务调度器实现

构建简单的协程调度系统：

class Scheduler {
    protected $maxTaskId = 0;
    protected $taskMap = []; // taskId => task
    protected $taskQueue;

    public function __construct() {
        $this->taskQueue = new SplQueue();
    }

    public function newTask(Generator $coroutine) {
        $tid = ++$this->maxTaskId;
        $task = new Task($tid, $coroutine);
        $this->taskMap[$tid] = $task;
        $this->schedule($task);
        return $tid;
    }

    public function schedule(Task $task) {
        $this->taskQueue->enqueue($task);
    }

    public function run() {
        while (!$this->taskQueue->isEmpty()) {
            $task = $this->taskQueue->dequeue();
            $task->run();

            if ($task->isFinished()) {
                unset($this->taskMap[$task->getTaskId()]);
            } else {
                $this->schedule($task);
            }
        }
    }
}

class Task {
    // 实现略...
}

三、协程网络请求实战

模拟非阻塞IO操作：

function fetchUrl($url) {
    // 模拟异步IO
    $result = yield "开始请求 $url";
    echo "收到响应: $resultn";
    yield "处理完成";
}

$scheduler = new Scheduler();
$scheduler->newTask(fetchUrl('https://example.com/api1'));
$scheduler->newTask(fetchUrl('https://example.com/api2'));
$scheduler->run();

四、协程与Promise结合

现代PHP协程编程模式：

class Promise {
    private $value;
    private $callbacks = [];

    public function then(callable $callback) {
        $this->callbacks[] = $callback;
    }

    public function resolve($value) {
        $this->value = $value;
        foreach ($this->callbacks as $callback) {
            $callback($value);
        }
    }
}

function asyncOperation() {
    return new Promise();
}

function coroutine() {
    $result = yield asyncOperation();
    echo "异步操作结果: $resultn";
}

五、实际应用场景

• 高并发爬虫：同时处理数千个页面请求
• 微服务调用：并行调用多个服务接口
• 批量数据处理：大文件分块处理
• 实时消息队列：高效处理异步任务

// 爬虫示例
function spider($urls) {
    foreach ($urls as $url) {
        $content = yield fetchUrl($url);
        $data = parseContent($content);
        yield saveToDatabase($data);
    }
}

六、性能对比测试

七、Swoole扩展对比

原生协程与Swoole协程的差异：

• 原生Generator：轻量级，但功能有限
• Swoole协程：完整协程支持，需要安装扩展
• 性能对比：Swoole在IO密集型场景优势明显