| commit | 6254d120c938f3a2a7b59ab373d6e8348ef98bec | [log] [tgz] |
|---|---|---|
| author | Albumen Kevin <jhq0812@gmail.com> | Tue Aug 16 17:42:34 2022 +0800 |
| committer | Albumen Kevin <jhq0812@gmail.com> | Tue Aug 16 17:42:34 2022 +0800 |
| tree | b95e70c075a548f79e4a9f84d553f1c0ad011b79 | |
| parent | 14343cf9009b5985b50582e2fbf4b9469e8bd23b [diff] | |
| parent | fabff5720ccc70b80e5812412e38e61e8492aed4 [diff] |
Merge branch 'apache-3.0' into apache-3.1
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