I used the same code posted above only changing syntax needed to create Coro and OS threads.
This is not working code but the only difference is my actual code has functions that connect to vendor api.

OS thread code

#!/usr/bin/perl
$|=1;
print "Start time ".(localtime). "\n";
use strict;
use threads;
use CGI qw(:standard);
use XML::Simple;
use JSON qw(encode_json);
use MIME::Base64 qw(encode_base64);
use DBI;
use SOAP::Lite;
use POSIX qw(ceil);
use Data::Dumper;
use CHI;
$XML::Simple::PREFERRED_PARSER='XML::Parser';
$SOAP::Constants::DO_NOT_USE_CHARSET = 1;

my (@req,@odata,@errdet)=();
    my %threads=();
    foreach my $vnd (@req){
        #$threads{$vnd}=threads->create({ 'context' => 'list', 'exit' 
+=> 'thread_only' },\&startthread,$vnd,$SCH);
        $threads{$vnd}=async{&startthread($vnd,$SCH) };
    }
    cede;
    foreach my $vnd (keys %threads) 
    {
        my($err,$data) =$threads{$vnd}->join();
        if ($err eq 'N') {
            push @odata,@{$data};
        }
        }elseif($err eq 'Y'){
            push @errdet,$data;
        }elsif($threads{$vnd}->error) # with threads it was useful,
        {
            push @errdet,{ Vnd=>$vnd, ErrorCode=>26,ErrorMsg=>$threads
+{$vnd}->error};
        }
     }    


sub startthread
{
    my ($vendor,$SCH)=@_;
    my($err,$data) =();
    require './'.$vendor.'functions.pl"; #load vendor specific code
    ($err,$data)=&getvendordata($SCH);
    return($err,$data);
}

#vendor functions has somewhat code like this besides functions specif
+ic to each vendor api
#fetch data serially in a loop waiting for each call to finish before 
+going on next
sub getvendordata
{
    my $SCH=shift;
    #perform vendor specific tasks mostly SOAP::Lite calls to api
    #Has to perform multiple calls some of them depend on output of pr
+evious calls
    #Also have to make simultaneous calls which may not be related to 
+each other can be done parallelly.
    #e.g. first call to api returns a list of products subsequent call
+s to fetch details.
    #If i start threads/forks again here most of the time program cras
+hes :(
    my ($err,@data)=();
    my @products=getproduects();
        #Maybe i can start coro routines here to get all listed detail
+s simultaneously
    foreach my $product (@products)
    {
        #fetch product details over api
        push @data,$product->getdetails;
    }
    return ($err,\@data);
}
[download]

Coro Code

use strict;
use Coro;
#use Coro::LWP;
use LWP::Protocol::AnyEvent::http;
use CGI qw(:standard);
use XML::Simple;
use JSON qw(encode_json);
use MIME::Base64 qw(encode_base64);
use DBI;
use POSIX qw(ceil);
use Data::Dumper;
use CHI;
use SOAP::Lite;
use SOAP::Transport::HTTP; 
$XML::Simple::PREFERRED_PARSER='XML::Parser';
$SOAP::Constants::DO_NOT_USE_CHARSET = 1;

my (@req,@odata,@errdet)=();
    my %threads=();
    foreach my $vnd (@req){
        #$threads{$vnd}=threads->create({ 'context' => 'list', 'exit' 
+=> 'thread_only' },\&startthread,$vnd,$SCH);
        $threads{$vnd}=async{&startthread($vnd,$SCH) };
    }
    cede;
    foreach my $vnd (keys %threads) 
    {
        my($err,$data) =$threads{$vnd}->join();
        if ($err eq 'N') {
            push @odata,@{$data};
        }
        }elseif($err eq 'Y'){
            push @errdet,$data;
        }elsif($threads{$vnd}->error) # with threads it was useful,
        {
            push @errdet,{ Vnd=>$vnd, ErrorCode=>26,ErrorMsg=>$threads
+{$vnd}->error};
        }
     }    


sub startthread
{
    my ($vendor,$SCH)=@_;
    my($err,$data) =();
    require './'.$vendor.'functions.pl"; #load vendor specific code
    ($err,$data)=&getvendordata($SCH);
    return($err,$data);
}

#vendor functions has somewhat code like this besides functions specif
+ic to each vendor api
#fetch data asyncronously with coro async for each product
sub getvendordata
{
    my $SCH=shift;
    #perform vendor specific tasks mostly SOAP::Lite calls to api
    #Has to perform multiple calls some of them depend on output of pr
+evious calls
    #Also have to make simultaneous calls which may not be related to 
+each other can be done parallelly.
    #e.g. first call to api returns a list of products subsequent call
+s to fetch details.
    #If i start threads/forks again here most of the time program cras
+hes :(
    my ($err,@data)=();
    my @products=getproduects();
        #Maybe i can start coro routines here to get all listed detail
+s simultaneously
    my @tasks=();
    foreach my $product (@products)
    {
        #fetch product details over api
        push @tasks,async {push @data,$product->getdetails};
    }
    foreach my $task (@ftasks) {        $task->join();    }
    return ($err,\@data);
}
[download]

I wait for all threads to finish by joining them.

---

---

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.