www.gusucode.com > Catfish(鲶鱼) CMS系统 PHP版 v4.8.21源码程序 > Catfishcms_v4.8.21/vendor/topthink/think-queue/src/driver/Sync.php
<?php // +---------------------------------------------------------------------- // | ThinkPHP [ WE CAN DO IT JUST THINK IT ] // +---------------------------------------------------------------------- // | Copyright (c) 2006-2015 http://thinkphp.cn All rights reserved. // +---------------------------------------------------------------------- // | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 ) // +---------------------------------------------------------------------- // | Author: yunwuxin <448901948@qq.com> // +---------------------------------------------------------------------- namespace think\queue\driver; use Exception; use think\queue\job\Sync as SyncJob; use Throwable; class Sync { public function push($job, $data = '', $queue = null) { $queueJob = $this->resolveJob($this->createPayload($job, $data, $queue)); try { set_time_limit(0); $queueJob->fire(); } catch (Exception $e) { $queueJob->failed(); throw $e; } catch (Throwable $e) { $queueJob->failed(); throw $e; } return 0; } public function later($delay, $job, $data = '', $queue = null) { return $this->push($job, $data, $queue); } public function pop($queue = null) { } protected function resolveJob($payload) { return new SyncJob($payload); } protected function createPayload($job, $data = '', $queue = null) { return json_encode(['job' => $job, 'data' => $data]); } }