Re: MultiThreaded Program in perl

[BrowserUk]

in reply to MultiThreaded Program in perl

Simplistically:

#! perl -slw
use strict;
use threads;
use Thread::Queue;
use DBI;


our $N //= 4;

sub child {
    my $Q = shift;
    while( my $work = $Q->dequeue ) {
        for my $thing ( @{ $work } ) {
            ## process data items
        }
    }
}

my $Q = new Thread::Queue;

my @kids = map threads->create( \&child, $Q ), 1 .. $N;

my $dbh = DBI->connect( ... );
my $sth->prepare( ...SQL HERE... );

while( my $ref = sth->fetch_* ) {
    $Q->enqueue( share_clone( $ref ) );
}

### Assume exiting the loop above means no more data
$dbh->disconnect;

## tell the kids to die
$Q->enqueue( ( undef ) x $N );

## And wait for kids to clean up
$_->join for @kids;;

[dtate]

Wow, I wish I would of found this thread before I hacked around with Parallel fork manager, Thanks for this Example

[Anonymous Monk]

Hi,
I am getting the following error when I tried to throw an error from my child thread.

Error: Reached EOF after 0 bytes, header is minimum 4 bytes
Operation """": no method found, argument in overloaded package main at /home/jpotter/testscript.pl

Any Idea what the above error is?
Thanks!

[BrowserUk]

Any Idea what the above error is?

None whatsoever.