Skip to content

Commit 8a02f9a

Browse files
lexburnercarryxyh
authored andcommitted
Bugfix/timeout queue full (#3451)
replace ArrayBlockingQueue with LinkedBlockingQueue and remove capacity.
1 parent b757e19 commit 8a02f9a

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

dubbo-common/src/main/java/org/apache/dubbo/common/timer/HashedWheelTimer.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -25,9 +25,9 @@
2525
import java.util.Locale;
2626
import java.util.Queue;
2727
import java.util.Set;
28-
import java.util.concurrent.ArrayBlockingQueue;
2928
import java.util.concurrent.CountDownLatch;
3029
import java.util.concurrent.Executors;
30+
import java.util.concurrent.LinkedBlockingQueue;
3131
import java.util.concurrent.RejectedExecutionException;
3232
import java.util.concurrent.ThreadFactory;
3333
import java.util.concurrent.TimeUnit;
@@ -109,8 +109,8 @@ public class HashedWheelTimer implements Timer {
109109
private final HashedWheelBucket[] wheel;
110110
private final int mask;
111111
private final CountDownLatch startTimeInitialized = new CountDownLatch(1);
112-
private final Queue<HashedWheelTimeout> timeouts = new ArrayBlockingQueue<HashedWheelTimeout>(1024);
113-
private final Queue<HashedWheelTimeout> cancelledTimeouts = new ArrayBlockingQueue<HashedWheelTimeout>(1024);
112+
private final Queue<HashedWheelTimeout> timeouts = new LinkedBlockingQueue<>();
113+
private final Queue<HashedWheelTimeout> cancelledTimeouts = new LinkedBlockingQueue<>();
114114
private final AtomicLong pendingTimeouts = new AtomicLong(0);
115115
private final long maxPendingTimeouts;
116116

0 commit comments

Comments
 (0)