Server IP : 92.204.138.22 / Your IP : 3.144.232.239 Web Server : Apache System : Linux ns1009439.ip-92-204-138.us 4.18.0-553.8.1.el8_10.x86_64 #1 SMP Tue Jul 2 07:26:33 EDT 2024 x86_64 User : internationaljou ( 1019) PHP Version : 7.4.33 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : ON Directory : /usr/share/doc/perl-Thread-Queue/examples/ |
Upload File : |
#!/usr/bin/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