onTask

发布于 2015-08-09 09:40:42 | 188 次阅读 | 评论: 0 | 来源: 网络整理

在task_worker进程内被调用。worker进程可以使用swoole_server_task函数向task_worker进程投递新的任务。

function onTask((swoole_server $serv, int $task_id, int $from_id, string $data));

• $task_id是任务ID，由swoole扩展内自动生成，用于区分不同的任务。$task_id和$from_id组合起来才是全局唯一的，不同的worker进程投递的任务ID可能会有相同
• $from_id来自于哪个worker进程
• $data 是任务的内容

1.7.2以前的版本，$data的长度最大不得超过8K，此参数受SW_BUFFER_SIZE宏控制
1.7.2以上的版本，$data的长度不受限制，如果超过SW_BUFFER_SIZE，将自动写入临时文件

返回执行结果到worker进程

1.7.2以上的版本，在onTask函数中 return字符串，表示将此内容返回给worker进程。worker进程中会触发onFinish函数，表示投递的task已完成。

1.7.2以前的版本，需要调用swoole_server->finish()函数将结果返回给worker进程