欢迎来到 54818模板网!这是一个yzmcms的模板分享站。

/** (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'];
}

    上一篇:return_message

    下一篇:已经是最后一篇

    作者:54818模板网 关注:56 时间:2024-10-19 14:40:57
    相关网站教程