view release on metacpan or  search on metacpan

t/2-do_batch.t  view on Meta::CPAN

    push @result, 'a', \@param;
}, b => sub {
    my ($d_b, @param) = @_;
    push @result, 'b', \@param;
} });
@result = (); $d->run();
is_deeply \@result, ['a',['first'],'b',[{second=>2}]], 'extra params (HASH)';

# - task return results:
#   * no result
#   * some result
#   * throw error

$d = Async::Defer->new();
$d->do([ sub{
    my ($d_1) = @_;
    $d_1->done(10,11,12);
}, sub {
    my ($d_2) = @_;
    $d_2->throw('error');
}, sub {
    my ($d_3) = @_;
    $d_3->done();
} ]);
$d->do(sub{
    my ($d, @results) = @_;
    @result = @results;
    $d->done();
});
@result = (); $d->run();
is_deeply \@result, [[10,11,12],'error',[]], 'results (ARRAY)';

$d = Async::Defer->new();
$d->do({ a => sub{
    my ($d_a) = @_;
    $d_a->done(10,11,12);
}, b => sub {
    my ($d_b) = @_;
    $d_b->throw('error');
}, c => sub {
    my ($d_c) = @_;
    $d_c->done();
} });
$d->do(sub{
    my ($d, @results) = @_;
    %result = @results;
    $d->done();
});
%result = (); $d->run();
is_deeply \%result, {a=>[10,11,12],b=>'error',c=>[]}, 'results (HASH)';

# - some tasks are CODE, some Defer objects
#   * they all doesn't share state (except ref-vars in same Defer clones)

my %seen;

$d = Async::Defer->new();
$d->do(sub{
    my ($d, @param) = @_;
    $param[0]++;
    $d->{t} = AE::timer 0.01, 0, sub { $d->done(@param) };
});
$d->do(sub{
    my ($d, @param) = @_;
    $seen{$d} = 1;
    push @result, {
        type => 'Defer',
        param=> \@param,
        state=> $d->{state}++,
        share=> ${$d->{share}}++,
    };
    $d->done(@param);
});
$d->{state} = 5;
$d->{share} = \do{my $tmp = 1};

sub code {
    my ($d, @param) = @_;
    $seen{$d} = 1;
    push @result, {
        type => 'sub',
        param=> \@param,
        state=> $d->{state}++,
        share=> ${$d->{share}}++,
    };
    $d->done(@param);
}

$p = Async::Defer->new();
$p->do([ \&code, \&code, $d, $d, sub{
    my ($d, @param) = @_;
    $seen{$d} = 1;
    push @result, {
        type => 'anon',
        param=> \@param,
        state=> $d->{state}++,
        share=> ${$d->{share}}++,
    };
    $d->done(@param);
} ]);
$p->do(sub{
    my ($p, @results) = @_;
    push @result, @results;
    $p->done();
});
(%seen, @result) = ();
$t = AE::timer 0.01, 0, sub{ $p->run(undef, [10], [20], [30], [40], [50]) };
$tx= AE::timer 0.5,  0, sub{ $cv->send };
$cv = AE::cv; $cv->recv;
is scalar(keys %seen), 5, 'all batch objects are different (ARRAY)';
is_deeply \@result, [
    { type=>'sub',      state=>0,   share=>0,   param=>[10] },
    { type=>'sub',      state=>0,   share=>0,   param=>[20] },
    { type=>'anon',     state=>0,   share=>0,   param=>[50] },
    { type=>'Defer',    state=>5,   share=>1,   param=>[31] },
    { type=>'Defer',    state=>5,   share=>2,   param=>[41] },
    [10], [20], [31], [41], [50],
    ], 'they all does not share state (ARRAY)';

$p = Async::Defer->new();
$p->do({ sub1=>\&code, sub2=>\&code, defer1=>$d, defer2=>$d, anon=>sub{
    my ($d, @param) = @_;
    $seen{$d} = 1;
    push @result, {
        type => 'anon',
        param=> \@param,
        state=> $d->{state}++,
        share=> ${$d->{share}}++,
    };
    $d->done(@param);
} });
$p->do(sub{
    my ($p, @results) = @_;
    %result = @results;
    $p->done();
});
(%seen, @result, %result) = ();
$t = AE::timer 0.01, 0, sub{ $p->run(undef, sub1=>[10], sub2=>[20], defer1=>[30], defer2=>[40], anon=>[50]) };
$tx= AE::timer 0.5,  0, sub{ $cv->send };
$cv = AE::cv; $cv->recv;
is scalar(keys %seen), 5, 'all batch objects are different (HASH)';
@result = sort { $a->{param}[0] <=> $b->{param}[0] } @result;
is_deeply \@result, [
    { type=>'sub',      state=>0,   share=>0,   param=>[10] },
    { type=>'sub',      state=>0,   share=>0,   param=>[20] },
    { type=>'Defer',    state=>5,   share=>3,   param=>[31] },
    { type=>'Defer',    state=>5,   share=>4,   param=>[41] },
    { type=>'anon',     state=>0,   share=>0,   param=>[50] },
    ], 'they all does not share state (HASH)';
is_deeply \%result, {sub1=>[10], sub2=>[20], defer1=>[31], defer2=>[41], anon=>[50]},
    '… results (HASH)';