| … | … | ||
|---|---|---|---|
| 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; |
| – | Removed lines |
| + | Added lines |
| < | Changed lines |
| > | Changed lines |