commit | 9ba4fe3ce67053a104d3023db1894ecb180628e6 | [log] [tgz] |
---|---|---|
author | Albumen Kevin <jhq0812@gmail.com> | Tue Aug 16 17:42:48 2022 +0800 |
committer | Albumen Kevin <jhq0812@gmail.com> | Tue Aug 16 17:42:48 2022 +0800 |
tree | c34ad93798d95b792a2f583c44ee52f039857b3a | |
parent | 41e1603f24c0d564e6db282d3ca44cc4b1cea5f7 [diff] | |
parent | 6254d120c938f3a2a7b59ab373d6e8348ef98bec [diff] |
Merge branch 'apache-3.1' into 3.1.0-release
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