| … | … | ||
|---|---|---|---|
| 241 | my $cb; | 241 | my $cb; |
| 242 | 242 | ||
| 243 | while () { | 243 | while () { |
| 244 | eval { | 244 | eval { |
| 245 | while () { | 245 | while () { |
| 246 | # &{&_pool_1 or &terminate}; # crashes, would be ~5% faster | ||
| 247 | $cb = &_pool_1 | 246 | _pool_1 $cb; |
| 248 | or &terminate; | ||
| 249 | &$cb; | 247 | &$cb; |
| 250 | undef $cb; | 248 | _pool_2 $cb; |
| 251 | &terminate if &_pool_2; | ||
| 252 | &schedule; | 249 | &schedule; |
| 253 | } | 250 | } |
| 254 | }; | 251 | }; |
| 255 | 252 | ||
| 253 | last if $@ eq "\3terminate\2\n"; | ||
| 256 | warn $@ if $@; | 254 | warn $@ if $@; |
| 257 | } | 255 | } |
| 258 | } | 256 | } |
| 259 | 257 | ||
| 260 | sub async_pool(&@) { | 258 | sub async_pool(&@) { |
| – | Removed lines |
| + | Added lines |
| < | Changed lines |
| > | Changed lines |