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