swoole中task阻塞会有什么影响,如何解决或避免阻塞
Admin 2022-07-21 群英技术资讯 1676 次浏览
这篇文章给大家介绍了“swoole中task阻塞会有什么影响,如何解决或避免阻塞”的相关知识,讲解详细,步骤过程清晰,有一定的借鉴学习价值,因此分享给大家做个参考,感兴趣的朋友接下来一起跟随小编看看吧。
如果有仔细看过 swoole task 的文档的话,应该都会注意到这句话
task操作的次数必须小于onTask处理速度,如果投递容量超过处理能力,task会塞满缓存区,导致worker进程发生阻塞。
worker进程将无法接收新的请求 (推荐学习: swoole视频教程)
task 如果阻塞会引发 woker 进程阻塞,造成服务无法工作,引发问题。
我曾经使用 task 发送服务的链路日志,接收日志的服务出现bug,造成发送日志的 task 阻塞,然后服务 gg 的情况,之后我就对 task 做了一波优化。
思路就是使用 swoole channel 和 swoole user process 实现一套 task 。
使用 channel 接收数据,然后在 user process 消费数据,假如 channel 满了仅仅会造成 push 数据失败,并不会引发阻塞,因为是链路日志,是允许丢失的,所以这个方案完全没问题。
在swoole user process 消费 channel 的策略的伪代码如下
$sleepTime = 5;
$maxSleepTime = 100;
while (true) {
$task = $chan->pop();
if ($task === false) {
$sleepTime = $sleepTime + 5;
if ($sleepTime > $maxSleepTime) {
$sleepTime = $maxSleepTime;
}
usleep($sleepTime * 1000);
continue;
}
$sleepTime = 0;
// 处理数据
}如果消费到channel的数据,就使用死循环处理数据,因为处理数据过程中是有其他操作的,所以并不会占用大量 cpu。
如果消费不到数据,就 sleep 5ms,sleep的时间依次累加,直到达到最大值 100ms,达到 cpu 使用率和处理数据实时性的一个平衡,具体平衡点可以根据自己的业务按需调整。
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:mmqy2019@163.com进行举报,并提供相关证据,查实之后,将立刻删除涉嫌侵权内容。
猜你喜欢
本篇文章给大家带来了关于laravel的相关知识,其中主要介绍了关于Laravel中的cache为我们提供了三种缓存机制:Redis,memcache,以及框架的文件缓存的相关内容,下面一起来看一下,希望对大家有帮助。
PHP命名空间作用是什么?很多人对于PHP命名空间还是比较陌生的,对于其作用以及用法都不是很清楚,因此这篇文章就主要给大家介绍一下如何定义命名空间和如何使用命名空间。
区别:1、Laravel在提交表单时需要在表单中加入“@csrf”来防止跨域攻击,而tp不需要添加;2、Laravel使用“Db::操作(‘原生sql’)”进行原生查询,而tp使用“Db::query(‘原生sql’)”进行原生查询。
今天小编就为大家分享一篇php 比较获取两个数组相同和不同元素的例子(交集和差集),具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
在本篇文章里小编给大家整理了一篇关于php查询类的方法总结内容,对此有兴趣的朋友们可以跟着学习下。
成为群英会员,开启智能安全云计算之旅
立即注册关注或联系群英网络
7x24小时售前:400-678-4567
7x24小时售后:0668-2555666
24小时QQ客服
群英微信公众号
CNNIC域名投诉举报处理平台
服务电话:010-58813000
服务邮箱:service@cnnic.cn
投诉与建议:0668-2555555
Copyright © QY Network Company Ltd. All Rights Reserved. 2003-2020 群英 版权所有
增值电信经营许可证 : B1.B2-20140078 ICP核准(ICP备案)粤ICP备09006778号 域名注册商资质 粤 D3.1-20240008