| Server IP : 188.40.95.74 / Your IP : 216.73.216.205 Web Server : Apache System : Linux cp01.striminghost.net 3.10.0-1160.119.1.el7.tuxcare.els13.x86_64 #1 SMP Fri Nov 22 06:29:45 UTC 2024 x86_64 User : vlasotin ( 1054) PHP Version : 5.6.40 Disable Function : NONE MySQL : ON | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : ON Directory : /usr/share/doc/perl-Thread-Queue-3.02/examples/ |
Upload File : |
#!/usr/bin/env perl
use strict;
use warnings;
use threads;
use Thread::Queue 3.01;
# Create a work queue for sending data to a 'worker' thread
# Prepopulate it with a few work items
my $work_q = Thread::Queue->new(qw/foo bar baz/);
# Create a status queue to get reports from the thread
my $status_q = Thread::Queue->new();
# Create a detached thread to process items from the queue
threads->create(sub {
# Keep grabbing items off the work queue
while (defined(my $item = $work_q->dequeue())) {
# Process the item from the queue
print("Thread got '$item'\n");
# Ask for more work when the queue is empty
if (! $work_q->pending()) {
print("\nThread waiting for more work\n\n");
$status_q->enqueue('more');
}
}
# Final report
print("Thread done\n");
$status_q->enqueue('done');
})->detach();
# More work for the thread
my @work = (
[ 'bippity', 'boppity', 'boo' ],
[ 'ping', 'pong' ],
[ 'dit', 'dot', 'dit' ],
);
# Send work to the thread
while ($status_q->dequeue() eq 'more') {
last if (! @work); # No more work
$work_q->enqueue(@{shift(@work)});
}
# Signal that there is no more work
$work_q->end();
# Wait for thread to terminate
$status_q->dequeue();
# Good-bye
print("Done\n");
# EOF