NAME

Thread::Task::Concurrent - Make simple task pocessing simple

SYNOPSIS

    use Thread::Task::Concurrent qw(tmsg);

    my @data = qw(a b c d e f g h i j k l m n o p q);

    my $tq = Thread::Task::Concurrent->new( task => \&task, max_instances => 4, verbose => 1 );
    my $result = $tq->enqueue(@data)->start->join->result;

    sub task {
        my $char = shift;

        # sleep some time
        my $sleep_time = int rand 10;
        sleep $sleep_time;

        #calculate result
        my $result = "I'm thread " . threads->tid . " and I slept $sleep_time sec. My result was " . $char x 3;

        return $result;
    }

DESCRIPTION

If you have input data and you want to pocess it in the same way, Thread::Task::Concurrent gives you an easy to use interface to getthingsdone(TM).

SUBROUTINES

tmsg($string_message)

tmsg($string_message, $tid_to_display)

Spits out the $string_message in the form:

    [thread_id] <message>

thread_id is by default threads->tid, but you can also set it artificially via the $tid_to_display variable.

METHODS

Thread::Task::Concurrent->new(%arg)

task => sub { ... }

Set the subroutine for the task. Example:

    sub {
        my ($item, $task_arg) = @_;
        
        return $result_item;
    }

arg => $task_arg

Add an additional arg hash/array/scalar to the task/subroutine call.

max_instances => 4

Set the maximum number of threads. Default is 4.

verbose => 0

Switch on/off verbose reporting.

$ttc = $ttc->start()

Start processing.

$ttc = $ttc->join()

Wait for processing end.

$ttc = $ttc->enqueue(@data)

Enqueue items.

$ttc = $ttc->result()

Gather the result.

ACCESSORS

$q = $ttc->queue

$rq = $ttc->result_queue

$task_code_ref = $ttc->task

$task_arg = $ttc->arg

$num = $ttc->max_instances

$threads = $ttc->threads

$is_verbose = $ttc->verbose

$is_finished = $ttc->finished

SEE ALSO

-

AUTHOR

jw bargsten, <cpan at bargsten dot org>