problem with dequeue

[bojandardic]

I have this perl script with additional thread "read_pipe" that read data from fifo pipe and enqueue that data to queue. On other end this data from queue should be read in main thread. Reading data from pipe and puting it on queue is OK, but main thread never get this data.

Why dequeue do not work?

I use openSuse 10.0 with installed perl 5.8.8.

Script:
#!/usr/local/bin/perl

use strict;
use Thread;
use Thread::Queue;

my $queue = new Thread::Queue;
my $read_pipe_thread = new Thread(\&read_pipe, $queue);
my $queue_read;
while (1) {
$queue_read = $queue->dequeue;
print "queue=" . $queue_read . "\n";
if ($queue_read eq "quit") {
print "quit program\n";
exit;
}
}
$queue->enqueue(undef);

sub read_pipe {
my ($queue) = @_;
my $fifo = '.fifo_pipe';
if (!(-e $fifo)) {
system('mkfifo', $fifo);
}
my $data;
open(FIFO, "+< $fifo") or die $!;
print "pipe opened\n";
while(<FIFO>) {
chomp($data = $_);
print "pipe=" . $data . "\n";
$queue->enqueue($data);
if ($data eq "quit") {
close(FIFO);
}
}
print "pipe closed\n";
if (-e $fifo) {
system('rm', $fifo);
}
}

Thanks.

 

[Kirsle]

For new code the use of the Thread module is discouraged and the direct use of the threads and threads::shared modules is encouraged instead.

use threads instead:

http://search.cpan.org/~jdhedden/threads-1.56/threads.pm

-------------
Cuvou.com | The NEW Kirsle.net

 

[bojandardic]

It works. Thanks for the tip.