Skip to content

Commit

Permalink
fix: signal at batch_size (#460)
Browse files Browse the repository at this point in the history
  • Loading branch information
fbogsany authored Oct 28, 2020
1 parent 406ac70 commit b96fbc6
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -75,7 +75,7 @@ def on_finish(span) # rubocop:disable Metrics/AbcSize
n = spans.size + 1 - max_queue_size
spans.shift(n) if n.positive?
spans << span
@condition.signal if spans.size > max_queue_size / 2
@condition.signal if spans.size > batch_size
end
end

Expand Down

0 comments on commit b96fbc6

Please sign in to comment.