首页
下载
文档
问答社区
视频
捐赠
源代码
AI 助理
赞助商
CRMEB
Apipost
腾讯云
微擎
禅道
51Talk
商业产品
Code-Galaxy
Swoole-Compiler
CRMEB 新零售社交电商系统
登录
注册
全部
提问
分享
讨论
建议
公告
开发框架
CodeGalaxy
发表新帖
swoole_server::on('Receive') 不使用 Task 是不是就會 Block
因為看了[使用Swoole异步发送邮件] 覺得該篇程式發信部份仍會同步造成 Worker 阻斷, 如果大量發信很快 swoole 就會被阻斷服務了，因此有了以下問題.... 請指教.... Q1. 如果 Receiver 做了非常耗時的工作，該 Worker 是不是就無法服務 {{{ $this->server->on('Receive', function(){ // 耗時任務 }); }}} Q2. 如果 Q1. 成立，把任務丟到 Task, Worker 就可以繼續服務？ {{{ $this->server->on('Receive', function($serv){ $task_id = $serv->task("耗時任務"); }); $this->server->on('Task', function(swoole_server $serv, int $task_id, int $from_id, string $data){ // 耗時任務" return "結果"; }); $this->server->on('Finish', function(swoole_server $serv, int $task_id, string $data){ // 任務結果後處理 }); }}} Q3. 丟給 Task 會失敗嗎？有Queue 嗎？Queue 長度？
发布于7年前 · 0 次浏览 · 来自
提问
f
fhb
因為看了[使用Swoole异步发送邮件] 覺得該篇程式發信部份仍會同步造成 Worker 阻斷, 如果大量發信很快 swoole 就會被阻斷服務了，因此有了以下問題.... 請指教.... Q1. 如果 Receiver 做了非常耗時的工作，該 Worker 是不是就無法服務 {{{ $this->server->on('Receive', function(){ // 耗時任務 }); }}} Q2. 如果 Q1. 成立，把任務丟到 Task, Worker 就可以繼續服務？ {{{ $this->server->on('Receive', function($serv){ $task_id = $serv->task("耗時任務"); }); $this->server->on('Task', function(swoole_server $serv, int $task_id, int $from_id, string $data){ // 耗時任務" return "結果"; }); $this->server->on('Finish', function(swoole_server $serv, int $task_id, string $data){ // 任務結果後處理 }); }}} Q3. 丟給 Task 會失敗嗎？有Queue 嗎？Queue 長度？
赞
0
分享
收藏
提问
分享
讨论
建议
公告
开发框架
CodeGalaxy
评论
2016-09-17
哈
哈哈
1. Worker进程如果阻塞，就无法再处理新的请求 2. 通过投递task是正确的做法，onTask中执行耗时任务，不会影响worker进程 3. task不会失败，是排队执行的，队列长度没有限制
赞
0
回复
微信公众号
热门内容
暂无回复的问答
- CodeGalaxy K3s 轻量集群节点之间如何实现负载均衡
- 关于openssl CURL WARNING swSSL_connect: SSL_connect(fd=69) failed. Error: error:141A318A:SSL routines:tls_process_ske_dhe:dh key too small[1|394]
- 多个模型如何进行事务异常回退？
- websocket开启wss报错
- 协程tcp服务器如何使用多进程？recv()方法接收信息，打印出来的pid一直是同一个。没用使用到多进程啊。
