| … | |
… | |
| 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 = '4.02'; |
55 | our $VERSION = '4.03'; |
| 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 | ); |
| … | |
… | |
| 255 | _pool_2 $cb; |
255 | _pool_2 $cb; |
| 256 | &schedule; |
256 | &schedule; |
| 257 | } |
257 | } |
| 258 | }; |
258 | }; |
| 259 | |
259 | |
| 260 | last if $@ eq "\3terminate\2\n"; |
260 | last if $@ eq "\3async_pool terminate\2\n"; |
| 261 | warn $@ if $@; |
261 | warn $@ if $@; |
| 262 | } |
262 | } |
| 263 | } |
263 | } |
| 264 | |
264 | |
| 265 | sub async_pool(&@) { |
265 | sub async_pool(&@) { |
