首页
下载
文档
社区
视频
捐赠
源代码
赞助商
AOT 编译器
AI 助理
商业产品
PHP AOT 原生编译器
Swoole-Compiler 代码加密器
CRMEB 新零售社交电商系统
登录
注册
全部
提问
分享
讨论
建议
公告
开发框架
CodeGalaxy
发表新帖
协程与wile（true）如何处理？
现有需求：从es查库处理后存库，期间会有数据处理过程。 已经实现：es查数据存redis 队列，然后使用 swoole 协程来消费队列，代码如下： ```php <?php \Co::set(['hook_flags' => SWOOLE_HOOK_NATIVE_CURL]); \Co\run(function() use ($date, $post) { $redisConfig = config('database.redis'); $pool = new RedisPool((new RedisConfig) ->withHost($redisConfig['host']) ->withPort($redisConfig['port']) ->withAuth($redisConfig['password'] ? $redisConfig['password'] : '') ->withDbIndex($redisConfig['database']) ->withTimeout(1) ); // 10k pdo and mysqli read for ($c = 50; $c--;) { Coroutine::create(function () use ($date, $post) { $redis = $pool->get(); while($es_data = $redis->brPop('UserList', 0)) { //业务逻辑处理，存数据库 } }); } }); ``` 问题1：我在协程中使用了我wile(true) 就导致协程永远不会退出，这样会不会有什么问题？ 问题2：现在速度优点慢，我除了在存数据库那一步又增加了协程处理存库的逻辑以外其他还有没有可以加快处理速度的方法？ 问题3：比假设我为了加快处理速度，增加for循环中的$c 的初始值，这样协程数很多，会有问题嘛？ 感谢回复！
发布于4年前 · 37 次浏览 · 来自
提问
埃贝赫
现有需求：从es查库处理后存库，期间会有数据处理过程。 已经实现：es查数据存redis 队列，然后使用 swoole 协程来消费队列，代码如下： ```php <?php \Co::set(['hook_flags' => SWOOLE_HOOK_NATIVE_CURL]); \Co\run(function() use ($date, $post) { $redisConfig = config('database.redis'); $pool = new RedisPool((new RedisConfig) ->withHost($redisConfig['host']) ->withPort($redisConfig['port']) ->withAuth($redisConfig['password'] ? $redisConfig['password'] : '') ->withDbIndex($redisConfig['database']) ->withTimeout(1) ); // 10k pdo and mysqli read for ($c = 50; $c--;) { Coroutine::create(function () use ($date, $post) { $redis = $pool->get(); while($es_data = $redis->brPop('UserList', 0)) { //业务逻辑处理，存数据库 } }); } }); ``` 问题1：我在协程中使用了我wile(true) 就导致协程永远不会退出，这样会不会有什么问题？ 问题2：现在速度优点慢，我除了在存数据库那一步又增加了协程处理存库的逻辑以外其他还有没有可以加快处理速度的方法？ 问题3：比假设我为了加快处理速度，增加for循环中的$c 的初始值，这样协程数很多，会有问题嘛？ 感谢回复！
赞
0
收藏
提问
分享
讨论
建议
公告
开发框架
CodeGalaxy
登录
后参与评论
评论
2022-01-07
Rango
你需要设计一种退出机制，比如接收信号或者指令后，退出协程。 ```php $running = true; Swoole\Process::signal(SIGTERM, function () use ($running) { $running = false; }); while($running and $es_data = $redis->brPop('UserList', 0)) { //业务逻辑处理，存数据库 } ``` 协程只能解决 IO 并发的问题，如果你的程序存在大量计算逻辑，是无法通过协程解决的，可以使用 `Swoole\Process\Pool` 开多个工作进程并行处理。 多个协程可以并发请求，可以加快速度。但需要确保你的业务代码中没有阻塞 IO ，否则会导致进程阻塞。
赞
1
回复
2022-03-11
掸尘
mark
赞
0
回复
