NAME
Queue::Worker - Database based work queue abstraction.
SYNOPSIS
package MyWorker;
use base 'Queue::Worker';
sub name { 'my_work'; }
sub process {
my ($self, $item) = @_;
# do your work here
}
# create worker table in db
MyWorker->create_table($dbh);
# and somewhere else
MyWorker->enqueue($dbh, 'some work order string');
# and finally to run the queue
MyWorker->run($dbh);DESCRIPTION
This module provides simple, database queue based, worker abstraction. It provides locking between worker instances using POSIX::RT::Semaphore.
Strings representing work orders are enqueued with enqueue function. Those items are removed from the queue by run function.
METHODS
$class->create_table($dbh, $name)
Creates table queue_worker_$name table in the database. $name parameter is optional: if undef name accessor is used.
$class->enqueue($dbh, $msg)
Enqueues work order $msg into the queue.
$class->new
Creates new instance of the worker. Also creates underlying semaphore.
$class->run($dbh)
Runs the queue. Calls process method on each work item.
$class->unlink_semaphore
Unlinks semaphore.
$class->get_semaphore
Returns underlying semaphore.
ABSTRACT METHODS
The following methods should be implemented by inherited class.
$class->name
Should return the name of the worker.
$self->process($msg)
Callback to process the work order.
AUTHOR
Boris Sukholitko
CPAN ID: BOSU
boriss@gmail.comCOPYRIGHT
This program is free software; you can redistribute it and/or modify it under the same terms as Perl itself.
The full text of the license can be found in the LICENSE file included with this module.