… | … | ||
---|---|---|---|
233 | our $POOL_SIZE = 8; | 233 | our $POOL_SIZE = 8; |
234 | our @pool; | 234 | our @pool; |
235 | 235 | ||
236 | sub pool_handler { | 236 | sub pool_handler { |
237 | while () { | 237 | while () { |
238 | my ($cb, @arg) = @{ delete $current->{_invoke} }; | ||
239 | |||
240 | eval { | 238 | eval { |
239 | my ($cb, @arg) = @{ delete $current->{_invoke} }; | ||
241 | $cb->(@arg); | 240 | $cb->(@arg); |
242 | }; | 241 | }; |
243 | warn $@ if $@; | 242 | warn $@ if $@; |
244 | 243 | ||
245 | last if @pool >= $POOL_SIZE; | 244 | last if @pool >= $POOL_SIZE; |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |