首页
下载
文档
社区
视频
捐赠
源代码
赞助商
AOT 编译器
AI 助理
商业产品
PHP AOT 原生编译器
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 長度？
发布于10年前 · 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
回复