ProcessorQueue
class ProcessorQueue extends Processor (View source)
Properties
| protected | $target | from Processor | |
| protected | $tasks | ||
| protected | $itemsPerBatch | ||
| protected | $queue |
Methods
finish()
No description
getTotalTasks()
No description
process()
Takes the current queue, and fills it based on the currently registered tasks and the registered processor.
int
getItemsPerBatch()
No description
setItemsPerBatch(int $itemsPerBatch)
No description
setQueue(Queue $queue)
No description
getQueue()
No description
__sleep()
No description
receive()
No description
Details
__construct(TargetInterface $target)
No description
registerTask(TaskInterface $task, $priority = 0)
No description
execute(ActionInterface $action)
No description
finish()
No description
getTasks()
No description
getTotalTasks()
No description
process()
Takes the current queue, and fills it based on the currently registered tasks and the registered processor.
int
getItemsPerBatch()
No description
setItemsPerBatch(int $itemsPerBatch)
No description
setQueue(Queue $queue)
No description
getQueue()
No description
__sleep()
No description
receive()
No description