\think\queueWorker

daemon()

daemon(string  $queue = null, integer  $delay, integer  $memory = 128, integer  $sleep = 3, integer  $maxTries) : array

启动一个守护进程执行任务.

Parameters

Returns

pop()

pop(string  $queue = null, integer  $delay, integer  $sleep = 3, integer  $maxTries) : array

执行下个任务

Parameters

Returns

process()

process(\think\queue\Job  $job, integer  $maxTries, integer  $delay) : array

Process a given job from the queue.

Parameters

Throws

\Exception

Returns

memoryExceeded()

memoryExceeded(integer  $memoryLimit) : boolean

检查内存是否超出

Parameters

Returns

stop()

stop() : void

停止执行任务的守护进程.

sleep()

sleep(integer  $seconds) : void

Sleep the script for a given number of seconds.

Parameters

runNextJobForDaemon()

runNextJobForDaemon(string  $queue, integer  $delay, integer  $sleep, integer  $maxTries) : void

以守护进程的方式执行下个任务.

Parameters

getNextJob()

getNextJob(string  $queue) 

获取下个任务

Parameters

logFailedJob()

logFailedJob(\Think\Queue\Job  $job) : array

Log a failed job into storage.

Parameters

Returns

getTimestampOfLastQueueRestart()

getTimestampOfLastQueueRestart() : integer|null

获取上次重启守护进程的时间

Returns

queueShouldRestart()

queueShouldRestart(integer|null  $lastRestart) : boolean

检查是否要重启守护进程

Parameters

Returns

getExceptionHandler()

getExceptionHandler() : \think\exception\Handle

获取异常处理实例

Returns