swoole_server->task

发布于 2015-08-09 09:38:21 | 248 次阅读 | 评论: 0 | 来源: 网络整理

投递一个异步任务到task_worker池中。此函数会立即返回。worker进程可以继续处理新的请求。

bool swoole_server::task(mixed $data, int $dst_worker_id = -1) 
$task_id = $serv->task("some data");

• $data要投递的任务数据，可以为除资源类型之外的任意PHP变量
• $dst_worker_id可以制定要给投递给哪个task进程，传入ID即可，范围是0 - serv->task_worker_num
• 返回值为整数($task_id)，表示此任务的ID。如果有finish回应，onFinish回调中会携带$task_id参数

$dst_worker_id在1.6.11+后可用，默认为随机投递
task方法不能在task进程中调用

此功能用于将慢速的任务异步地去执行，比如一个聊天室服务器，可以用它来进行发送广播。当任务完成时，在task进程中调用$serv->finish("finish")告诉worker进程此任务已完成。当然swoole_server->finish是可选的。

AsyncTask功能在1.6.4版本增加，默认不启动task功能，需要在手工设置task_worker_num来启动此功能
task_worker的数量在swoole_server::set参数中调整，如task_worker_num => 64，表示启动64个进程来接收异步任务

注意事项

• 使用swoole_server_task必须为Server设置onTask和onFinish回调，否则swoole_server->start会失败
• task操作的次数必须小于onTask处理速度，如果投递容量超过处理能力，task会塞满缓存区，导致worker进程发生阻塞。worker进程将无法接收新的请求