commit | fabff5720ccc70b80e5812412e38e61e8492aed4 | [log] [tgz] |
---|---|---|
author | Andy Cheung <win120a@users.noreply.github.com> | Tue Aug 16 17:39:18 2022 +0800 |
committer | GitHub <noreply@github.com> | Tue Aug 16 17:39:18 2022 +0800 |
tree | 89640e7e5dad305eb86489cc11fc8e2e8cb0b3fb | |
parent | 43c4033e11c07a59cb052a4ee7a18b95b26de707 [diff] |
Backport of 'Fix bug of always rejecting in MemorySafeLinkedBlockingQueue'. (#10471)
diff --git a/dubbo-common/src/main/java/org/apache/dubbo/common/threadpool/MemorySafeLinkedBlockingQueue.java b/dubbo-common/src/main/java/org/apache/dubbo/common/threadpool/MemorySafeLinkedBlockingQueue.java index 3c1ae24..8aa3e12 100644 --- a/dubbo-common/src/main/java/org/apache/dubbo/common/threadpool/MemorySafeLinkedBlockingQueue.java +++ b/dubbo-common/src/main/java/org/apache/dubbo/common/threadpool/MemorySafeLinkedBlockingQueue.java
@@ -100,8 +100,9 @@ public void put(final E e) throws InterruptedException { if (hasRemainedMemory()) { super.put(e); + } else { + rejector.reject(e, this); } - rejector.reject(e, this); } @Override