| … | |
… | |
| 50 | |
50 | |
| 51 | our $idle; # idle handler |
51 | our $idle; # idle handler |
| 52 | our $main; # main coroutine |
52 | our $main; # main coroutine |
| 53 | our $current; # current coroutine |
53 | our $current; # current coroutine |
| 54 | |
54 | |
| 55 | our $VERSION = '3.3'; |
55 | our $VERSION = '3.5'; |
| 56 | |
56 | |
| 57 | our @EXPORT = qw(async async_pool cede schedule terminate current unblock_sub); |
57 | our @EXPORT = qw(async async_pool cede schedule terminate current unblock_sub); |
| 58 | our %EXPORT_TAGS = ( |
58 | our %EXPORT_TAGS = ( |
| 59 | prio => [qw(PRIO_MAX PRIO_HIGH PRIO_NORMAL PRIO_LOW PRIO_IDLE PRIO_MIN)], |
59 | prio => [qw(PRIO_MAX PRIO_HIGH PRIO_NORMAL PRIO_LOW PRIO_IDLE PRIO_MIN)], |
| 60 | ); |
60 | ); |
| … | |
… | |
| 234 | our @pool; |
234 | our @pool; |
| 235 | |
235 | |
| 236 | sub pool_handler { |
236 | sub pool_handler { |
| 237 | while () { |
237 | while () { |
| 238 | eval { |
238 | eval { |
| 239 | my ($cb, @arg) = @{ delete $current->{_invoke} }; |
239 | my ($cb, @arg) = @{ delete $current->{_invoke} or return }; |
| 240 | $cb->(@arg); |
240 | $cb->(@arg); |
| 241 | }; |
241 | }; |
| 242 | warn $@ if $@; |
242 | warn $@ if $@; |
| 243 | |
243 | |
| 244 | last if @pool >= $POOL_SIZE; |
244 | last if @pool >= $POOL_SIZE; |
