… | … | ||
---|---|---|---|
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 |