拿平時大家寫的 for 循環(huán)舉例。像 go 你可以寫兩個 go 每個里面各寫一個循環(huán)同時輸入,你可以看到輸出是交替。在過去的 php 版本中,如果只開啟一個 cli 寫多個 for 循環(huán),那么他的輸出一定是順序的。無法做到交叉輸出(也就是無法在第一個循環(huán)中執(zhí)行若干次后,讓 b 再執(zhí)行,b 執(zhí)行一段時間后,再讓 A 執(zhí)行)?,F(xiàn)在借助 fiber 我們也可以實現(xiàn)這種操作。下面這段代碼就可以做到兩個循環(huán)交叉執(zhí)行。甚至可以控制兩個程序執(zhí)行的頻率(比如 A 執(zhí)行 3 次,B 執(zhí)行一次這樣分配)
<?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
個人理解fiber相當于實現(xiàn)的程序全文“主?!?順序執(zhí)行)之外,可以把其中的部分代碼通過fiber封裝,該部分代碼的“?!笨梢愿鶕?jù)需求切換執(zhí)行,增加了程序控制的靈活性