/** (V7.1 新增) * 下发队列任务 * @param string $job 队列任务类名称 * @param array $params 传入的参数 * @param string $queue 队列名称 * @return string|false 任务id */ function dispatch($job, $params = array(), $queue = ''){ $res = yzm_base::load_job($job, 0); if(!$res) return $res; $object = new $job($params); yzm_base::load_sys_class('queue_factory','',0); $data = array( 'uuid' => md5(create_randomstr()), 'job' => $job, 'object' => serialize($object), 'attempts' => 0, 'create_time' => SYS_TIME ); queue_factory::get_instance()->lpush($queue ? $queue : trim(C('queue_name')), $data); return $data['uuid']; }
dispatch
上一篇:return_message
下一篇:已经是最后一篇
有问题可以加入织梦技术QQ群一起交流学习
本站vip会员 请加入 VIP②群 PS:加入时备注用户名或昵称
普通注册会员或访客 请加入技术交流②群
作者:54818模板网 关注:56 时间:2024-10-19 14:40:57
相关网站教程: