github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-24 06:37:19 -04:00
Code Issues Projects Releases Packages Wiki Activity

MINOR: Use more optimal loop in draining QUeue

Browse source 
Fixes #8101
This commit is contained in:
Armin 2017-08-29 23:39:30 +02:00 • committed by Armin Braun
parent 848e1c1aef
commit a658c46b43
1 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

8
logstash-core/src/main/java/org/logstash/common/LsQueueUtils.java
View file

@ -37,13 +37,13 @@ public final class LsQueueUtils {
int left = count;
final Collection<JrubyEventExtLibrary.RubyEvent> collection =
new HashSet<>(4 * count / 3 + 1);
while (left > 0) {
do {
final int drained = drain(queue, collection, left, nanos);
if (drained == 0) {
break;
}
left -= drained;
}
} while (left > 0);
return collection;
}
@ -65,7 +65,7 @@ public final class LsQueueUtils {
final long nanos) throws InterruptedException {
final long deadline = System.nanoTime() + nanos;
int added = 0;
while (added < count) {
do {
added += queue.drainTo(collection, count - added);
if (added < count) {
final JrubyEventExtLibrary.RubyEvent event =
@ -76,7 +76,7 @@ public final class LsQueueUtils {
collection.add(event);
added++;
}
}
} while (added < count);
return added;
}