We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 5392b16 commit 896b13aCopy full SHA for 896b13a
1 file changed
httpcore5/src/main/java/org/apache/hc/core5/reactor/MultiCoreIOReactor.java
@@ -102,7 +102,9 @@ public final void awaitShutdown(final TimeValue waitTime) throws InterruptedExce
102
}
103
for (int i = 0; i < this.threads.length; i++) {
104
final Thread thread = this.threads[i];
105
- thread.join(TimeUnit.NANOSECONDS.toMillis(remainingNanos));
+ final long millis = TimeUnit.NANOSECONDS.toMillis(remainingNanos);
106
+ final int nanos = (int) (remainingNanos - TimeUnit.MILLISECONDS.toNanos(millis));
107
+ thread.join(millis, nanos);
108
remainingNanos = deadlineNanos - System.nanoTime();
109
if (remainingNanos <= 0) {
110
return;
0 commit comments