协程的使用

// #[GetMapping(path: "test")]
function test(){
    //使用 create 创建协程
    echo '当前协程 ' . Coroutine::id() . PHP_EOL;
    Coroutine::create(function () {
        echo '使用 create 方法创建协程，协程 ID ' . Coroutine::id() . PHP_EOL;
    });
    //判断当前环境是否处于协程环境内
    var_dump(Coroutine::inCoroutine());
    //当前协程id
    echo Coroutine::id();

    //channel通道
    co(function () {//创建协程
        //使用通道
        $channel = new \Swoole\Coroutine\Channel();
        co(function () use ($channel) {
            $message = Coroutine::id() . ' ，来自 parent 的数据';
            $channel->push($message);
        });
        $data = $channel->pop();
        echo Coroutine::id() . ', 收到 parent 的数据：' . $data . PHP_EOL;
    });

    //Defer 特性 协程结束时运行一些代码
    echo 'start' . PHP_EOL;
    go(function () {
        echo 'init' . PHP_EOL;
        Coroutine::defer(function () {
            echo "第一个defer".PHP_EOL;
        });
        Coroutine::defer(function(){
            echo "第二个defer".PHP_EOL;
        });
        Coroutine::defer(function(){
            echo "第三个defer".PHP_EOL;
        });
        echo 'defer end'.PHP_EOL;
    });
    echo 'end' . PHP_EOL;


    /**
     * WaitGroup 特性
     * 这段代码创建了一个 WaitGroup 对象 $wg，并通过调用 add 方法将计数器增加了2。
        WaitGroup 是 Hyperf 框架提供的一个同步原语，用于协调多个协程的执行。它主要用于等待一组协程执行完成后再继续执行后续逻辑。
        在上述代码中，add 方法用于增加计数器的值。通过传入一个正整数作为参数，可以将计数器的值增加相应的次数。在这里，计数器增加了2次，表示有两个协程需要等待。
        通常，在创建协程时，我们会使用 go 函数来执行协程任务，并在协程任务执行完成后调用 done 方法来减少计数器的值。当计数器的值减少到0时，表示所有协程任务都已完成，主线程可以继续执行后续逻辑。
        */
    $wg = new \Hyperf\Utils\WaitGroup();
    // 计数器加二
    $wg->add(2);//表示有两个协程需要等待

    // 创建协程 A
    go(function () use ($wg) {
        mt_srand();
        $time = mt_rand(1, 3);
        sleep($time);
        echo "协程 A 执行完成" . PHP_EOL;
        // 计数器减一
        $wg->done();
    });
    // 创建协程 B
    go(function () use ($wg) {
        mt_srand();
        $time = mt_rand(1, 3);
        sleep($time);
        echo "协程 B 执行完成" . PHP_EOL;

        // 计数器减一
        $wg->done();
    });

    $wg->wait();
    echo "全部程序执行完成" . PHP_EOL;


    /**
     * 这个应该是最重要的了
     * Paraller 特性
     * Parallel 特性是 Hyperf 基于 WaitGroup 特性抽象出来的一个更便捷的使用方法。
     * use Hyperf\Utils\Exception\ParallelExecutionException;
        use Hyperf\Utils\Parallel;
        * 这段代码使用了 Parallel 类来并行执行多个协程任务，并获取它们的返回值。
        在代码中，首先创建了一个 Parallel 对象，指定并行执行的数量为 10。然后使用 add 方法向 Parallel 对象中添加了 20 个协程任务。每个协程任务都会获取当前的毫秒级时间戳，并将其追加到 a.log 文件中。最后使用 wait 方法等待所有协程任务执行完毕，并获取它们的返回值。
        在 try 块中，如果协程任务中出现了异常，可以通过 ParallelExecutionException 异常捕获并处理。可以使用 getResults 方法获取协程任务的返回值，使用 getThrowables 方法获取协程任务中出现的异常。
        */
    //同时运行的最大协程数量是 10
    //创建了20个协程
    //所以分两批执行的 中间间隔5秒
    $parallel = new Parallel(10);
    for ($i = 0; $i < 20; $i++) {
        $parallel->add(function () {
                sleep(5);
            file_put_contents('./a.log',date('H:i:s'.time()).PHP_EOL,FILE_APPEND);
            return Coroutine::id();
        });
    }
    try{
        $results = $parallel->wait();
        print_r($results);
    } catch(ParallelExecutionException $e){
        echo $e->getResults();// 获取协程中的返回值。
        echo $e->getThrowables();// 获取协程中出现的异常。
    }

    /**
     * Concurrent
     * 控制一个代码块内同时运行的最大协程数量
     */
    $concurrent = new Coroutine\Concurrent(10);
    for ($i = 0; $i < 15; ++$i) {
        $concurrent->create(function () {
            sleep(1);
            echo Coroutine::id() . '==' . mt_rand() . PHP_EOL;
        });
    }

    //协程上下文
    go(function () {//创建一个协程 比如id是2
        Context::set('name', '王美丽');
        go(function () {//创建一个协程 按顺序增加的 id=3
            // 不会输出 name 的值
            echo Context::get('name');
            echo Coroutine::id() . PHP_EOL;
        });
        // 输出当前协程中 name 的值
        Context::override('name');
        echo Coroutine::id() . ' ' . Context::get('name');
    });
}