ZhouXY108/hutool
1
0
Fork 0
mirror of https://gitee.com/chinabugotech/hutool.git synced 2025-05-09 23:51:34 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix code

Browse Source
This commit is contained in:
Looly 2023-05-04 15:51:11 +08:00
parent c64baff56f
commit 1dfbc48117
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
hutool-core/src/main/java/org/dromara/hutool/core/collection/queue/MemorySafeLinkedBlockingQueue.java
View File

@ -11,6 +11,7 @@
*/ */
package org.dromara.hutool.core.collection.queue; package org.dromara.hutool.core.collection.queue;
import org.dromara.hutool.core.lang.Console;
import org.dromara.hutool.core.thread.SimpleScheduler; import org.dromara.hutool.core.thread.SimpleScheduler;
import org.dromara.hutool.core.util.RuntimeUtil; import org.dromara.hutool.core.util.RuntimeUtil;
@ -87,6 +88,7 @@ public class MemorySafeLinkedBlockingQueue<E> extends CheckedLinkedBlockingQueue
@Override @Override
public boolean test(final E e) { public boolean test(final E e) {
Console.log(FreeMemoryCalculator.INSTANCE.getResult());
return FreeMemoryCalculator.INSTANCE.getResult() > maxFreeMemory; return FreeMemoryCalculator.INSTANCE.getResult() > maxFreeMemory;
} }
} }
@ -99,7 +101,7 @@ public class MemorySafeLinkedBlockingQueue<E> extends CheckedLinkedBlockingQueue
FreeMemoryCalculator() { FreeMemoryCalculator() {
super(new SimpleScheduler.Job<Long>() { super(new SimpleScheduler.Job<Long>() {
private volatile long maxAvailable; private volatile long maxAvailable = RuntimeUtil.getFreeMemory();
@Override @Override
public Long getResult() { public Long getResult() {