fiber 使用方式

缝合

拿平时大家写的 for 循环举例。像 go 你可以写两个 go 每个里面各写一个循环同时输入,你可以看到输出是交替。在过去的 php 版本中,如果只开启一个 cli 写多个 for 循环,那么他的输出一定是顺序的。无法做到交叉输出(也就是无法在第一个循环中执行若干次后,让 b 再执行,b 执行一段时间后,再让 A 执行)。现在借助 fiber 我们也可以实现这种操作。下面这段代码就可以做到两个循环交叉执行。甚至可以控制两个程序执行的频率(比如 A 执行 3 次,B 执行一次这样分配)

<?php
ini_set('memory_limit', '-1');

class SuspendData
{
    public readonly Status $status;

    public function __construct($status)
    {
        $this->status = $status;
    }
}

enum Status
{
    case Stop;
    case Running;
}

$t1  = false;
$t2  = false;
$reg = [];
$fId = 1;

$reg[] = new \Fiber(function () use ($fId) {
    for ($i = 1; $i < 10; $i++) {
        echo $fId . ':' . $i;
        echo PHP_EOL;
        if ($i % 3 == 0) {
            \Fiber::suspend(new SuspendData(Status::Running));
        }
    }
    \Fiber::suspend(new SuspendData(Status::Stop));

});
$fId++;

$reg[] = new \Fiber(function () use ($fId) {
    for ($i = 1; $i < 10; $i++) {
        echo $fId . ':' . $i;
        echo PHP_EOL;
        \Fiber::suspend(new SuspendData(Status::Running));
    }
    \Fiber::suspend(new SuspendData(Status::Stop));
});

$startTag = true;
while (count($reg) > 0) {
    if ($startTag) foreach ($reg as $pI) {
        $pI->start();
        $startTag = false;
    }
    foreach ($reg as $key => $pI) {
        $r = $pI->resume();
        if ($r->status === Status::Stop) {
          unset($reg[$key]);
        }
    }
}

return 0;
1:1
1:2
1:3
2:1
1:4
1:5
1:6
2:2
1:7
1:8
1:9
2:3
2:4
2:5
2:6
2:7
2:8
2:9
2098 2 2
2个评论

artisan

个人理解fiber相当于实现的程序全文“主栈”(顺序执行)之外,可以把其中的部分代码通过fiber封装,该部分代码的“栈”可以根据需求切换执行,增加了程序控制的灵活性

  • alexyandy 2023-09-22

    这中代码是反人类的,php发展到这样的地步,真是不知道怎么说才好

  • 缝合 2023-09-25

    你发的这个是基于pthread的,扩展吧。php的这个 fiber 更多的是一个很底层的东西,是为了配合目前php的一些异步io库来使用的。定位不太一样。

suse

我看了几天fiber,感觉fiber就是分步执行代码,在suspend那里传递之前的结果,在resume那里获取结果并继续执行剩下的

  • 缝合 2023-09-26

    算是能更改执行力度,但是其他地方更合适用fiber。业务代码肯定不能直接用这个

缝合

790
积分
0
获赞数
0
粉丝数
2021-12-18 加入
🔝