org.dromara.hutool.core.collection.queue

Class MemorySafeLinkedBlockingQueue<E>

java.lang.Object

java.util.AbstractCollection<E>

java.util.AbstractQueue<E>

java.util.concurrent.LinkedBlockingQueue<E>

org.dromara.hutool.core.collection.queue.CheckedLinkedBlockingQueue<E>

org.dromara.hutool.core.collection.queue.MemorySafeLinkedBlockingQueue<E>

Type Parameters:

E - 元素类型

All Implemented Interfaces:

Serializable, Iterable<E>, Collection<E>, BlockingQueue<E>, Queue<E>

public class MemorySafeLinkedBlockingQueue<E>
extends CheckedLinkedBlockingQueue<E>

内存安全的LinkedBlockingQueue，可以解决OOM问题。
原理是通过Runtime#freeMemory()获取剩余内存，当剩余内存低于指定的阈值时，不再加入。

此类来自于： Apache incubator-shenyu

Since:

6.0.0

Author:

incubator-shenyu

See Also:

Serialized Form

Field Summary

Fields inherited from class org.dromara.hutool.core.collection.queue.CheckedLinkedBlockingQueue

checker

Constructor Summary

Constructors

Constructor and Description
MemorySafeLinkedBlockingQueue(Collection<? extends E> c, long maxFreeMemory) 构造
MemorySafeLinkedBlockingQueue(long maxFreeMemory) 构造

Method Summary

Modifier and Type	Method and Description
long	getMaxFreeMemory() get the max free memory.
void	setMaxFreeMemory(int maxFreeMemory) set the max free memory.

Methods inherited from class org.dromara.hutool.core.collection.queue.CheckedLinkedBlockingQueue

offer, offer, put

Methods inherited from class java.util.concurrent.LinkedBlockingQueue

clear, contains, drainTo, drainTo, iterator, peek, poll, poll, remainingCapacity, remove, size, spliterator, take, toArray, toArray, toString

Methods inherited from class java.util.AbstractQueue

add, addAll, element, remove

Methods inherited from class java.util.AbstractCollection

containsAll, isEmpty, removeAll, retainAll

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.concurrent.BlockingQueue

add

Methods inherited from interface java.util.Queue

element, remove

Methods inherited from interface java.util.Collection

addAll, containsAll, equals, hashCode, isEmpty, parallelStream, removeAll, removeIf, retainAll, stream

Methods inherited from interface java.lang.Iterable

forEach

Constructor Detail

MemorySafeLinkedBlockingQueue

public MemorySafeLinkedBlockingQueue(long maxFreeMemory)

构造

Parameters:

maxFreeMemory - 最大剩余内存大小，当实际内存小于这个值时，不再加入元素

MemorySafeLinkedBlockingQueue

public MemorySafeLinkedBlockingQueue(Collection<? extends E> c,
                                     long maxFreeMemory)

构造

Parameters:

c - 初始集合

maxFreeMemory - 最大剩余内存大小，当实际内存小于这个值时，不再加入元素

Method Detail

setMaxFreeMemory

public void setMaxFreeMemory(int maxFreeMemory)

set the max free memory.

Parameters:

maxFreeMemory - the max free memory

getMaxFreeMemory

public long getMaxFreeMemory()

get the max free memory.

Returns:

the max free memory limit