We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 6815e2a commit 50ceb1bCopy full SHA for 50ceb1b
1 file changed
src/main/java/com/timgroup/statsd/StatsDProcessor.java
@@ -91,6 +91,12 @@ protected void processLoop() {
91
closeSignal.countDown();
92
clientClosed = true;
93
}
94
+ if (clientClosed) {
95
+ // We are draining highPrioMessages, which is a non-blocking
96
+ // queue. Avoid a busy loop if the queue is empty while the aggregator
97
+ // is flushing.
98
+ Thread.sleep(WAIT_SLEEP_MS);
99
+ }
100
continue;
101
102
0 commit comments