NAME

Pots::MessageQueue - Perl ObjectThreads thread safe message queue

SYNOPSIS

use threads;
my $q = Pots::MessageQueue->new();
sub thread_proc {
my $rmsg;
my $quit = 0;
while (!$quit) {
$rmsg = $q->getmsg();
for ($rmsg->type()) {
if (/quit/) {
$quit = 1;
} else {
print "thread received a message of type $_\n";
}
}
}
}
my $th = threads->new("thread_proc");
my $msg = Pots::Message->new('type');
$q->postmsg($msg);
$msg->type('quit');
$q->postmsg($msg);

DESCRIPTION

Pots::MessageQueue objects allows threads to communicate using messages. It is built upon a standard Thread::Queue object, and uses Storable to serialize and deserialize messages between threads.

METHODS

new ()

Construct a new, shared, message queue object.

postmsg ($msg)

Posts a message in the queue, so that a thread can retrieve it using "getmsg()".

getmsg ()

Retrieves a message from the queue. If no message is available, this method will wait until a message becomes available.

nbmsg ()

Returns the number of messages waiting in the queue.

AUTHOR and COPYRIGHT

Remy Chibois <rchibois at free.fr>

Copyright (c) 2004 Remy Chibois. All rights reserved. This program is free software; you can redistribute it and/or modify it under the same terms as Perl itself.