Hi,
I am using this code to get the desired result and It works well. But It waits for all the child process to exit and then only it display the result.
What I want is as soon as on process retrieves the result it should display. It should not wait for all the process to get finished.
Variable Definition:
$serialized_searches: is a reference to a hash. key->integer value->object to class.
$search_string: Any string value
$res_man->site_modules: any module

$results = SOAP::Lite
        -> uri($PARASEARCH_CLIENT_URI)
        -> proxy($PARASEARCH_CLIENT_PROXY, timeout => $PARASEARCH_PARA
+LLEL_TIMEOUT + 15)
        -> parallel_search($serialized_searches, $search_string, $max_
+hits, $res_man->site_modules)
        -> result;
    };
[download]

sub parallel_search {
    my ($self, $serialized_searches, $rawsearch, $max_hits, $site_modu
+les) = @_;

    my (%return, $result_set);
    my $obj = Data::Serializer->new(
        serializer => 'Storable',
        portable => '1',
        encoding => 'b64',
    );
    my $searches = $obj->deserialize($serialized_searches);
    my $t0 = [gettimeofday];
    my $pm = new Parallel::ForkManager($PARASEARCH_MAX_PROCESSES);

    $pm->run_on_start(sub {
        my ($pid,$ident)=@_;
        
    });
    
    
    $pm->run_on_wait(sub {
            my ($pid, $ident) = @_;
    
            my $elapsed = tv_interval ( $t0, [gettimeofday]);
            my $remaining = scalar(keys %{$pm->{processes}});
            #print "$$ waiting ... $elapsed\n";
            #print STDERR " -- remaining $remaining\n";
            #print STDERR "processes " . $pm->{processes} . "\n";
            if ($elapsed > $PARASEARCH_PARALLEL_TIMEOUT) {
                # print STDERR "timeout exceeded $remaining processes 
+remain\n";
                foreach my $process (keys %{$pm->{processes}}) {
                    # print STDERR " .. $process\n";
                    kill 'TERM' => $process;
                }
            }
        },
        0.5
    );
    
    $pm->run_on_finish(sub {
        my ($pid, $exit_code, $ident) = @_;
                
        # print STDERR "database $ident done = exit $exit_code \n";
    });

    foreach my $key (keys %$searches) {
        my $pid = $pm->start($key) and next;

        if (-e $site_modules) {
            my @orig_inc = @INC;
            unshift (@INC, $site_modules);
            eval 'require ' . ref($$searches{$key}) . ';';
            @INC = @orig_inc;
        }
        else {
            eval 'require ' . ref($$searches{$key}) . ';';
        }
        if ($@) { print "error $@\n"; }
        my ($parsed_search, $result_set);
        eval {
            $parsed_search = $$searches{$key}->parse_search();
        };
        if ($@) {
            print STDERR "error parsing search: $@";
            $result_set = new DBWIZ::Search::ResultSet;
                        $result_set->status($@);
                        $result_set->hits(-6);
        }else{
            eval {
                $$searches{$key}->max_hits($max_hits);
                $result_set = $$searches{$key}->get_search_results($pa
+rsed_search, $key);
            };
            if ($@) {
                print STDERR "bad eval resource [$key]: $@ \n";
                $result_set = new DBWIZ::Search::ResultSet;
                $result_set->status($@);
                $result_set->hits(-3);
            }
        }    
        $result_set->rawsearch($rawsearch);
        eval {
            $obj->store($result_set, $PARASEARCH_SHARED_MEM . getppid 
+. escape($key));
        };
        if ($@) {
            print STDERR "from eval: $@ \n";
                        $result_set = new DBWIZ::Search::ResultSet;
                        $result_set->status($@);
                        $result_set->hits(-11);
        }
        $pm->finish;
    }
    $pm->wait_all_children;
    eval {
        foreach my $key (keys %$searches) {
            my $filename = $PARASEARCH_SHARED_MEM . $$ . escape($key);
            my $result_set;
            
            if (-e $filename) {
                $result_set = $obj->retrieve($filename);
                unlink($filename);
                
            }
            else {
                # need a new $timeout_result object every loop
                my $timeout_result = new DBWIZ::Search::ResultSet;
                $timeout_result->status('timeout');
                $timeout_result->hits(-5);
                $result_set = $timeout_result;
            }
            $return{$key} = $result_set;
        }
    };
    if ($@) { print STDERR "Problem with search module: $@\n"; }

    my $temp = $obj->serialize(\%return);
    return($temp);
}
[download]

---

---

Posts are HTML formatted. Put <p> </p> tags around your paragraphs. Put <code> </code> tags around your code and data!

Titles consisting of a single word are discouraged, and in most cases are disallowed outright.

Read Where should I post X? if you're not absolutely sure you're posting in the right place.

Please read these before you post! —

• How do I compose an effective node title?
• How do I post a question effectively?
• Markup in the Monastery

Posts may use any of the Perl Monks Approved HTML tags:

a, abbr, b, big, blockquote, br, caption, center, col, colgroup, dd, del, details, div, dl, dt, em, font, h1, h2, h3, h4, h5, h6, hr, i, ins, li, ol, p, pre, readmore, small, span, spoiler, strike, strong, sub, summary, sup, table, tbody, td, tfoot, th, thead, tr, tt, u, ul, wbr

You may need to use entities for some characters, as follows. (Exception: Within code tags, you can put the characters literally.)

	For:		Use:
	&		&
	<		&lt;
	>		&gt;
	[		&#91;
	]		&#93;

Link using PerlMonks shortcuts! What shortcuts can I use for linking?

See Writeup Formatting Tips and other pages linked from there for more info.