workbunny/event-loop
简介
一个event-loop实验品；
是一个类似ReactPHP、AMPHP的事件循环组件；
该项目主要研究ext-parallel和PHP-fiber在event-loop中如何有效结合，
研究PHP在不利用ext-event、ext-ev、ext-uv等拓展的前提下是否可以实现
更高的处理能力。
An event loop experiment;
It is an event loop component similar to ReactPHP and AMPHP;
This project mainly studies how ext-parallel and PHP-fiber can
be effectively combined in event-loop, and studies whether PHP
can achieve higher processing power without using extensions
like ext-event, ext-ev, ext-uv, etc.
使用
1. 安装
composer require workbunny/event-loop
2. 创建loop
use WorkBunny\EventLoop\Loop;
use WorkBunny\EventLoop\Drivers\NativeLoop;
use WorkBunny\EventLoop\Drivers\EventLoop;
use WorkBunny\EventLoop\Drivers\EvLoop;
use WorkBunny\EventLoop\Drivers\OpenSwooleLoop;
# 创建PHP原生loop
$loop = Loop::create(NativeLoop::class);
# 创建ext-event loop
$loop = Loop::create(EventLoop::class);
# 创建ext-ev loop
$loop = Loop::create(EvLoop::class);
# 创建ext-openswoole loop
$loop = Loop::create(OpenSwooleLoop::class);
3. 创建定时器
-
无延迟触发器
通过loop立即执行一次回调函数；
# 立即执行
$id = $loop->addTimer(0.0, 0.0, function (){
# 业务
});
-
延迟触发器
延迟 delay 参数的数值后，执行注册的回调函数，仅执行一次；
# 延迟1秒后执行一次
$id = $loop->addTimer(1.0, 0.0, function (){
# 业务
});
-
无延迟定时器
通过loop立即执行一次回调函数后，根据 repeat 参数的数值间隔执行，直到主动移除该定时器；
# 立即执行一次以后间隔0.1s执行
$id = $loop->addTimer(0.0, 0.1, function (){
# 业务
});
-
延迟定时器
延迟 delay 参数的数值后，执行一次注册的回调函数，之后根据 repeat 参数的数值间隔执行，直到主动移除该定时器；
# 延迟0.1s后间隔0.1s执行
$id = $loop->addTimer(0.1, 0.1, function (){
# 业务
});
# 延迟0.5s后间隔0.1s执行
$id = $loop->addTimer(0.5, 0.1, function (){
# 业务
});
4. 创建流事件
这里的流是指 PHP Streams
- 读取流
$loop->addReadStream(resource, function (){
# 业务
});
$loop->delReadStream(resource);
- 写入流
$loop->addWriteStream(resource, function (){
# 业务
});
$loop->delWriteStream(resource);
5. 创建信号事件
用于接收系统的信号，比如kill等
$loop->addSignal(\SIGUSR1, function (){
# 业务
});
$loop->delSignal(\SIGUSR1, function (){
# 业务
});
6. 启动/停止
-
启动
以下代码会持续阻塞，请放在程序最后一行
# 该函数后会阻塞
$loop->loop();
# 该行代码不会执行
var_dump('123');
-
停止
以下代码不会阻塞等待
$loop->destroy();
# 该行代码会执行
var_dump('123');
说明
1. 测试用例中各个loop比较特殊的地方会在对应测试用例中说明
- EvLoop 的Stream总是后于Timer 详见EvLoopTest.php
- EventLoop 的延迟定时器区别于其他Loop的定时器，需要多一个loop周期 详见EventLoopTest.php
- OpenSwoole 的读/写流不能通过 testReadStreamHandlerTriggeredMultiTimes 测试 详见OpenSwooleLoopTest.php
2. 相同定时器/触发器的优先级遵循先注册先触发
3. OpenSwoole在同一周期内是有优先级的
通过 Process::signal 设置的信号处理回调函数
通过 Timer::tick 和 Timer::after 设置的定时器回调函数
通过 Event::defer 设置的延迟执行函数
通过 Event::cycle 设置的周期回调函数
12.6k Dec 30, 2022
145 Jan 1, 2023
7 Aug 23, 2022
3.2k Jan 2, 2023
204 Dec 21, 2022
141 Jun 16, 2022
308 Dec 29, 2022
0 Jul 9, 2022
94 Jan 1, 2023
19 Aug 12, 2022
0 Jan 9, 2022
12 Nov 13, 2022
7 Jun 1, 2022
5.8k Dec 20, 2022
9.6k Jan 1, 2023
32 Dec 5, 2022
1.7k Jan 1, 2023