Package io.netty.util.internal
Class PlatformDependent
- java.lang.Object
-
- io.netty.util.internal.PlatformDependent
-
public final class PlatformDependent extends java.lang.ObjectUtility that detects various properties specific to the current runtime environment, such as Java version and the availability of thesun.misc.Unsafeobject.You can disable the use of
sun.misc.Unsafeif you specify the system property io.netty.noUnsafe.
-
-
Field Summary
Fields Modifier and Type Field Description static booleanBIG_ENDIAN_NATIVE_ORDER
-
Method Summary
All Methods Static Methods Concrete Methods Deprecated Methods Modifier and Type Method Description static intaddressSize()Return the address size of the OS. 4 (for 32 bits systems ) and 8 (for 64 bits systems).static longalign(long value, int alignment)static java.nio.ByteBufferalignDirectBuffer(java.nio.ByteBuffer buffer, int alignment)static CleanableDirectBufferallocateDirect(int capacity)Allocate a directByteBufferof the given capacity, and return it alongside its deallocation mechanism.static CleanableDirectBufferallocateDirectBufferNoCleaner(int capacity)static java.nio.ByteBufferallocateDirectNoCleaner(int capacity)Allocate a newByteBufferwith the givencapacity.static longallocateMemory(long size)static byte[]allocateUninitializedArray(int size)static intbitMode()Returns the bit mode of the current VM (usually 32 or 64.)static longbyteArrayBaseOffset()static booleancanEnableTcpNoDelayByDefault()Returnstrueif and only if it is fine to enable TCP_NODELAY socket option by default.static booleancanReliabilyFreeDirectBuffers()Returntrueif the selected cleaner can free direct buffers in a controlled way.static booleancompareAndSwapInt(java.lang.Object object, long fieldOffset, int expected, int value)static voidcopyMemory(byte[] src, int srcIndex, byte[] dst, int dstIndex, long length)static voidcopyMemory(byte[] src, int srcIndex, long dstAddr, long length)static voidcopyMemory(long srcAddr, byte[] dst, int dstIndex, long length)static voidcopyMemory(long srcAddr, long dstAddr, long length)static java.io.FilecreateTempFile(java.lang.String prefix, java.lang.String suffix, java.io.File directory)static java.nio.ByteBufferdirectBuffer(long memoryAddress, int size)static longdirectBufferAddress(java.nio.ByteBuffer buffer)static booleandirectBufferPreferred()Returnstrueif the platform has reliable low-level direct buffer access API and a user has not specified-Dio.netty.noPreferDirectoption.static booleanequals(byte[] bytes1, int startPos1, byte[] bytes2, int startPos2, int length)Compare twobytearrays for equality.static intequalsConstantTime(byte[] bytes1, int startPos1, byte[] bytes2, int startPos2, int length)Compare twobytearrays for equality without leaking timing information.static longestimateMaxDirectMemory()Compute an estimate of the maximum amount of direct memory available to this JVM.static java.lang.invoke.VarHandlefindVarHandleOfIntField(java.lang.invoke.MethodHandles.Lookup lookup, java.lang.Class<?> type, java.lang.String fieldName)static voidfreeDirectBuffer(java.nio.ByteBuffer buffer)Deprecated.Use theCleanableDirectBuffer.clean()fromallocateDirect(int)instead.static voidfreeDirectNoCleaner(java.nio.ByteBuffer buffer)This method MUST only be called forByteBuffers that were allocated viaallocateDirectNoCleaner(int).static voidfreeMemory(long address)static intgetAndAddInt(java.lang.Object object, long fieldOffset, int delta)static bytegetByte(byte[] data, int index)static bytegetByte(byte[] data, long index)static bytegetByte(long address)static java.lang.ClassLoadergetClassLoader(java.lang.Class<?> clazz)Return theClassLoaderfor the givenClass.static java.lang.ClassLoadergetContextClassLoader()Return the contextClassLoaderfor the currentThread.static intgetInt(byte[] data, int index)static intgetInt(int[] data, long index)static intgetInt(long address)static intgetInt(java.lang.Object object, long fieldOffset)static longgetLong(byte[] data, int index)static longgetLong(long address)static longgetLong(long[] data, long index)static java.lang.ObjectgetObject(java.lang.Object object, long fieldOffset)static shortgetShort(byte[] data, int index)static shortgetShort(long address)static java.lang.ClassLoadergetSystemClassLoader()Return the systemClassLoader.static java.lang.ThrowablegetUnsafeUnavailabilityCause()Return the reason (if any) whysun.misc.Unsafewas not available.static intgetVolatileInt(java.lang.Object object, long fieldOffset)static booleanhasAlignDirectByteBuffer()static booleanhasDirectBufferNoCleanerConstructor()static inthashCodeAscii(byte[] bytes, int startPos, int length)Calculate a hash code of a byte array assuming ASCII character encoding.static inthashCodeAscii(java.lang.CharSequence bytes)Calculate a hash code of a byte array assuming ASCII character encoding.static booleanhasUnsafe()Returntrueifsun.misc.Unsafewas found on the classpath and can be used for accelerated direct memory access.static booleanhasVarHandle()static java.lang.invoke.VarHandleintBeArrayView()static java.lang.invoke.VarHandleintBeByteBufferView()static java.lang.invoke.VarHandleintLeArrayView()static java.lang.invoke.VarHandleintLeByteBufferView()static booleanisAndroid()Returnstrueif and only if the current platform is Androidstatic booleanisExplicitNoPreferDirect()Returnstrueif user has specified-Dio.netty.noPreferDirect=trueoption.static booleanisIkvmDotNet()static booleanisJ9Jvm()static booleanisJfrEnabled()Check if JFR events are supported on this platform.static booleanisOsx()Returntrueif the JVM is running on OSX / MacOSstatic booleanisUnaligned()trueif and only if the platform supports unaligned access.static booleanisVirtualThread(java.lang.Thread thread)static booleanisWindows()Returntrueif the JVM is running on Windowsstatic booleanisZero(byte[] bytes, int startPos, int length)Determine if a subsection of an array is zero.static intjavaVersion()Return the version of Java under which this library is used.static java.lang.invoke.VarHandlelongBeArrayView()static java.lang.invoke.VarHandlelongBeByteBufferView()static java.lang.invoke.VarHandlelongLeArrayView()static java.lang.invoke.VarHandlelongLeByteBufferView()static longmaxDirectMemory()Returns the maximum memory reserved for direct buffer allocation.static booleanmaybeSuperUser()Returntrueif the current user may be a super-user.static <C> java.util.Deque<C>newConcurrentDeque()Returns a new concurrentDeque.static <K,V>
java.util.concurrent.ConcurrentMap<K,V>newConcurrentHashMap()Deprecated.please use new ConcurrentHashMap() directly. static <K,V>
java.util.concurrent.ConcurrentMap<K,V>newConcurrentHashMap(int initialCapacity)Deprecated.please use new ConcurrentHashMap() directly. static <K,V>
java.util.concurrent.ConcurrentMap<K,V>newConcurrentHashMap(int initialCapacity, float loadFactor)Deprecated.please use new ConcurrentHashMap() directly. static <K,V>
java.util.concurrent.ConcurrentMap<K,V>newConcurrentHashMap(int initialCapacity, float loadFactor, int concurrencyLevel)Deprecated.please use new ConcurrentHashMap() directly. static <K,V>
java.util.concurrent.ConcurrentMap<K,V>newConcurrentHashMap(java.util.Map<? extends K,? extends V> map)Deprecated.please use new ConcurrentHashMap() directly. static <T> java.util.Queue<T>newFixedMpmcQueue(int capacity)Create a newQueuewhich is safe to use for multiple producers (different threads) and multiple consumers with the given fixescapacity.static <T> java.util.Queue<T>newFixedMpscQueue(int capacity)Create a newQueuewhich is safe to use for multiple producers (different threads) and a single consumer (one thread!)static <T> java.util.Queue<T>newFixedMpscUnpaddedQueue(int capacity)Create a new un-paddedQueuewhich is safe to use for multiple producers (different threads) and a single consumer (one thread!)static LongCounternewLongCounter()Deprecated.please useLongAdderinstead.static <T> java.util.Queue<T>newMpscQueue()Create a newQueuewhich is safe to use for multiple producers (different threads) and a single consumer (one thread!).static <T> java.util.Queue<T>newMpscQueue(int maxCapacity)Create a newQueuewhich is safe to use for multiple producers (different threads) and a single consumer (one thread!).static <T> java.util.Queue<T>newMpscQueue(int chunkSize, int maxCapacity)Create a newQueuewhich is safe to use for multiple producers (different threads) and a single consumer (one thread!).static <T> java.util.Queue<T>newSpscQueue()Create a newQueuewhich is safe to use for single producer (one thread!)static java.lang.StringnormalizedArch()static java.util.Set<java.lang.String>normalizedLinuxClassifiers()static java.lang.StringnormalizedOs()static longobjectFieldOffset(java.lang.reflect.Field field)static java.nio.ByteBufferoffsetSlice(java.nio.ByteBuffer buffer, int index, int length)static voidputByte(byte[] data, int index, byte value)static voidputByte(long address, byte value)static voidputByte(java.lang.Object data, long offset, byte value)static voidputInt(byte[] data, int index, int value)static voidputInt(long address, int value)static voidputLong(byte[] data, int index, long value)static voidputLong(long address, long value)static voidputObject(java.lang.Object o, long offset, java.lang.Object x)static voidputOrderedInt(java.lang.Object object, long fieldOffset, int value)static voidputShort(byte[] data, int index, short value)static voidputShort(long address, short value)static CleanableDirectBufferreallocateDirectBufferNoCleaner(CleanableDirectBuffer buffer, int capacity)Reallocate a newByteBufferwith the givencapacity.static java.nio.ByteBufferreallocateDirectNoCleaner(java.nio.ByteBuffer buffer, int capacity)Reallocate a newByteBufferwith the givencapacity.static longreallocateMemory(long address, long newSize)static voidsetMemory(byte[] dst, int dstIndex, long bytes, byte value)static voidsetMemory(long address, long bytes, byte value)static java.lang.invoke.VarHandleshortBeArrayView()static java.lang.invoke.VarHandleshortBeByteBufferView()static java.lang.invoke.VarHandleshortLeArrayView()static java.lang.invoke.VarHandleshortLeByteBufferView()static java.util.RandomthreadLocalRandom()Deprecated.Use ThreadLocalRandom.current() instead.static voidthrowException(java.lang.Throwable t)Raises an exception bypassing compiler checks for checked exceptions.static java.io.Filetmpdir()Returns the temporary directory.static longusedDirectMemory()Returns the current memory reserved for direct buffer allocation.static booleanuseDirectBufferNoCleaner()
-
-
-
Method Detail
-
byteArrayBaseOffset
public static long byteArrayBaseOffset()
-
hasDirectBufferNoCleanerConstructor
public static boolean hasDirectBufferNoCleanerConstructor()
-
allocateUninitializedArray
public static byte[] allocateUninitializedArray(int size)
-
isAndroid
public static boolean isAndroid()
Returnstrueif and only if the current platform is Android
-
isWindows
public static boolean isWindows()
Returntrueif the JVM is running on Windows
-
isOsx
public static boolean isOsx()
Returntrueif the JVM is running on OSX / MacOS
-
maybeSuperUser
public static boolean maybeSuperUser()
Returntrueif the current user may be a super-user. Be aware that this is just an hint and so it may return false-positives.
-
javaVersion
public static int javaVersion()
Return the version of Java under which this library is used.
-
isVirtualThread
public static boolean isVirtualThread(java.lang.Thread thread)
- Parameters:
thread- The thread to be checked.- Returns:
trueif thisThreadis a virtual thread,falseotherwise.
-
canEnableTcpNoDelayByDefault
public static boolean canEnableTcpNoDelayByDefault()
Returnstrueif and only if it is fine to enable TCP_NODELAY socket option by default.
-
hasUnsafe
public static boolean hasUnsafe()
Returntrueifsun.misc.Unsafewas found on the classpath and can be used for accelerated direct memory access.
-
getUnsafeUnavailabilityCause
public static java.lang.Throwable getUnsafeUnavailabilityCause()
Return the reason (if any) whysun.misc.Unsafewas not available.
-
isUnaligned
public static boolean isUnaligned()
trueif and only if the platform supports unaligned access.- See Also:
- Wikipedia on segfault
-
directBufferPreferred
public static boolean directBufferPreferred()
Returnstrueif the platform has reliable low-level direct buffer access API and a user has not specified-Dio.netty.noPreferDirectoption.
-
isExplicitNoPreferDirect
public static boolean isExplicitNoPreferDirect()
Returnstrueif user has specified-Dio.netty.noPreferDirect=trueoption.
-
canReliabilyFreeDirectBuffers
public static boolean canReliabilyFreeDirectBuffers()
Returntrueif the selected cleaner can free direct buffers in a controlled way. This guarantee only applies for buffers allocated viaallocateDirect(int)and when using thecleanmethod of the returnedCleanableDirectBuffer.
-
maxDirectMemory
public static long maxDirectMemory()
Returns the maximum memory reserved for direct buffer allocation.
-
usedDirectMemory
public static long usedDirectMemory()
Returns the current memory reserved for direct buffer allocation. This method returns -1 in case that a value is not available.- See Also:
maxDirectMemory()
-
tmpdir
public static java.io.File tmpdir()
Returns the temporary directory.
-
bitMode
public static int bitMode()
Returns the bit mode of the current VM (usually 32 or 64.)
-
addressSize
public static int addressSize()
Return the address size of the OS. 4 (for 32 bits systems ) and 8 (for 64 bits systems).
-
allocateMemory
public static long allocateMemory(long size)
-
freeMemory
public static void freeMemory(long address)
-
reallocateMemory
public static long reallocateMemory(long address, long newSize)
-
throwException
public static void throwException(java.lang.Throwable t)
Raises an exception bypassing compiler checks for checked exceptions.
-
newConcurrentHashMap
@Deprecated public static <K,V> java.util.concurrent.ConcurrentMap<K,V> newConcurrentHashMap()
Deprecated.please use new ConcurrentHashMap() directly. Creates a new fastestConcurrentMapimplementation for the current platform.
-
newLongCounter
@Deprecated public static LongCounter newLongCounter()
Deprecated.please useLongAdderinstead.Creates a new fastestLongCounterimplementation for the current platform.
-
newConcurrentHashMap
@Deprecated public static <K,V> java.util.concurrent.ConcurrentMap<K,V> newConcurrentHashMap(int initialCapacity)
Deprecated.please use new ConcurrentHashMap() directly. Creates a new fastestConcurrentMapimplementation for the current platform.
-
newConcurrentHashMap
@Deprecated public static <K,V> java.util.concurrent.ConcurrentMap<K,V> newConcurrentHashMap(int initialCapacity, float loadFactor)Deprecated.please use new ConcurrentHashMap() directly. Creates a new fastestConcurrentMapimplementation for the current platform.
-
newConcurrentHashMap
@Deprecated public static <K,V> java.util.concurrent.ConcurrentMap<K,V> newConcurrentHashMap(int initialCapacity, float loadFactor, int concurrencyLevel)Deprecated.please use new ConcurrentHashMap() directly. Creates a new fastestConcurrentMapimplementation for the current platform.
-
newConcurrentHashMap
@Deprecated public static <K,V> java.util.concurrent.ConcurrentMap<K,V> newConcurrentHashMap(java.util.Map<? extends K,? extends V> map)
Deprecated.please use new ConcurrentHashMap() directly. Creates a new fastestConcurrentMapimplementation for the current platform.
-
allocateDirect
public static CleanableDirectBuffer allocateDirect(int capacity)
Allocate a directByteBufferof the given capacity, and return it alongside its deallocation mechanism.- Parameters:
capacity- The desired capacity of the direct byte buffer.- Returns:
- The
CleanableDirectBufferinstance that contain the buffer and its deallocation mechanism.
-
freeDirectBuffer
@Deprecated public static void freeDirectBuffer(java.nio.ByteBuffer buffer)
Deprecated.Use theCleanableDirectBuffer.clean()fromallocateDirect(int)instead.Try to deallocate the specified directByteBuffer. Please note this method does nothing if the current platform does not support this operation or the specified buffer is not a direct buffer.
-
directBufferAddress
public static long directBufferAddress(java.nio.ByteBuffer buffer)
-
directBuffer
public static java.nio.ByteBuffer directBuffer(long memoryAddress, int size)
-
hasVarHandle
public static boolean hasVarHandle()
-
findVarHandleOfIntField
public static java.lang.invoke.VarHandle findVarHandleOfIntField(java.lang.invoke.MethodHandles.Lookup lookup, java.lang.Class<?> type, java.lang.String fieldName)
-
intBeArrayView
public static java.lang.invoke.VarHandle intBeArrayView()
-
intLeArrayView
public static java.lang.invoke.VarHandle intLeArrayView()
-
longBeArrayView
public static java.lang.invoke.VarHandle longBeArrayView()
-
longLeArrayView
public static java.lang.invoke.VarHandle longLeArrayView()
-
shortBeArrayView
public static java.lang.invoke.VarHandle shortBeArrayView()
-
shortLeArrayView
public static java.lang.invoke.VarHandle shortLeArrayView()
-
longBeByteBufferView
public static java.lang.invoke.VarHandle longBeByteBufferView()
-
longLeByteBufferView
public static java.lang.invoke.VarHandle longLeByteBufferView()
-
intBeByteBufferView
public static java.lang.invoke.VarHandle intBeByteBufferView()
-
intLeByteBufferView
public static java.lang.invoke.VarHandle intLeByteBufferView()
-
shortBeByteBufferView
public static java.lang.invoke.VarHandle shortBeByteBufferView()
-
shortLeByteBufferView
public static java.lang.invoke.VarHandle shortLeByteBufferView()
-
getObject
public static java.lang.Object getObject(java.lang.Object object, long fieldOffset)
-
getVolatileInt
public static int getVolatileInt(java.lang.Object object, long fieldOffset)
-
getInt
public static int getInt(java.lang.Object object, long fieldOffset)
-
putOrderedInt
public static void putOrderedInt(java.lang.Object object, long fieldOffset, int value)
-
getAndAddInt
public static int getAndAddInt(java.lang.Object object, long fieldOffset, int delta)
-
compareAndSwapInt
public static boolean compareAndSwapInt(java.lang.Object object, long fieldOffset, int expected, int value)
-
getByte
public static byte getByte(long address)
-
getShort
public static short getShort(long address)
-
getInt
public static int getInt(long address)
-
getLong
public static long getLong(long address)
-
getByte
public static byte getByte(byte[] data, int index)
-
getByte
public static byte getByte(byte[] data, long index)
-
getShort
public static short getShort(byte[] data, int index)
-
getInt
public static int getInt(byte[] data, int index)
-
getInt
public static int getInt(int[] data, long index)
-
getLong
public static long getLong(byte[] data, int index)
-
getLong
public static long getLong(long[] data, long index)
-
putByte
public static void putByte(long address, byte value)
-
putShort
public static void putShort(long address, short value)
-
putInt
public static void putInt(long address, int value)
-
putLong
public static void putLong(long address, long value)
-
putByte
public static void putByte(byte[] data, int index, byte value)
-
putByte
public static void putByte(java.lang.Object data, long offset, byte value)
-
putShort
public static void putShort(byte[] data, int index, short value)
-
putInt
public static void putInt(byte[] data, int index, int value)
-
putLong
public static void putLong(byte[] data, int index, long value)
-
putObject
public static void putObject(java.lang.Object o, long offset, java.lang.Object x)
-
objectFieldOffset
public static long objectFieldOffset(java.lang.reflect.Field field)
-
copyMemory
public static void copyMemory(long srcAddr, long dstAddr, long length)
-
copyMemory
public static void copyMemory(byte[] src, int srcIndex, long dstAddr, long length)
-
copyMemory
public static void copyMemory(byte[] src, int srcIndex, byte[] dst, int dstIndex, long length)
-
copyMemory
public static void copyMemory(long srcAddr, byte[] dst, int dstIndex, long length)
-
setMemory
public static void setMemory(byte[] dst, int dstIndex, long bytes, byte value)
-
setMemory
public static void setMemory(long address, long bytes, byte value)
-
allocateDirectNoCleaner
public static java.nio.ByteBuffer allocateDirectNoCleaner(int capacity)
Allocate a newByteBufferwith the givencapacity.ByteBuffers allocated with this method MUST be deallocated viafreeDirectNoCleaner(ByteBuffer).
-
allocateDirectBufferNoCleaner
public static CleanableDirectBuffer allocateDirectBufferNoCleaner(int capacity)
Allocate a newByteBufferwith the givencapacity, inside aCleanableDirectBuffer. TheByteBufferMUST be deallocated via theCleanableDirectBuffer.clean()of the returnedCleanableDirectBufferobject.
-
reallocateDirectNoCleaner
public static java.nio.ByteBuffer reallocateDirectNoCleaner(java.nio.ByteBuffer buffer, int capacity)Reallocate a newByteBufferwith the givencapacity.ByteBuffers reallocated with this method MUST be deallocated viafreeDirectNoCleaner(ByteBuffer).
-
reallocateDirectBufferNoCleaner
public static CleanableDirectBuffer reallocateDirectBufferNoCleaner(CleanableDirectBuffer buffer, int capacity)
Reallocate a newByteBufferwith the givencapacity. TheByteBufferis given as wrapped in its associatedCleanableDirectBuffer, and a newCleanableDirectBufferinstance will be returned. TheByteBuffers reallocated with this method MUST be deallocated via theCleanableDirectBuffer.clean()method on the returned object.
-
freeDirectNoCleaner
public static void freeDirectNoCleaner(java.nio.ByteBuffer buffer)
This method MUST only be called forByteBuffers that were allocated viaallocateDirectNoCleaner(int).
-
hasAlignDirectByteBuffer
public static boolean hasAlignDirectByteBuffer()
-
alignDirectBuffer
public static java.nio.ByteBuffer alignDirectBuffer(java.nio.ByteBuffer buffer, int alignment)
-
align
public static long align(long value, int alignment)
-
offsetSlice
public static java.nio.ByteBuffer offsetSlice(java.nio.ByteBuffer buffer, int index, int length)
-
useDirectBufferNoCleaner
public static boolean useDirectBufferNoCleaner()
-
equals
public static boolean equals(byte[] bytes1, int startPos1, byte[] bytes2, int startPos2, int length)Compare twobytearrays for equality. For performance reasons no bounds checking on the parameters is performed.- Parameters:
bytes1- the first byte array.startPos1- the position (inclusive) to start comparing inbytes1.bytes2- the second byte array.startPos2- the position (inclusive) to start comparing inbytes2.length- the amount of bytes to compare. This is assumed to be validated as not going out of bounds by the caller.
-
isZero
public static boolean isZero(byte[] bytes, int startPos, int length)Determine if a subsection of an array is zero.- Parameters:
bytes- The byte array.startPos- The starting index (inclusive) inbytes.length- The amount of bytes to check for zero.- Returns:
falseifbytes[startPos:startsPos+length)contains a value other than zero.
-
equalsConstantTime
public static int equalsConstantTime(byte[] bytes1, int startPos1, byte[] bytes2, int startPos2, int length)Compare twobytearrays for equality without leaking timing information. For performance reasons no bounds checking on the parameters is performed.The
intreturn type is intentional and is designed to allow cascading of constant time operations:byte[] s1 = new {1, 2, 3}; byte[] s2 = new {1, 2, 3}; byte[] s3 = new {1, 2, 3}; byte[] s4 = new {4, 5, 6}; boolean equals = (equalsConstantTime(s1, 0, s2, 0, s1.length) & equalsConstantTime(s3, 0, s4, 0, s3.length)) != 0;- Parameters:
bytes1- the first byte array.startPos1- the position (inclusive) to start comparing inbytes1.bytes2- the second byte array.startPos2- the position (inclusive) to start comparing inbytes2.length- the amount of bytes to compare. This is assumed to be validated as not going out of bounds by the caller.- Returns:
0if not equal.1if equal.
-
hashCodeAscii
public static int hashCodeAscii(byte[] bytes, int startPos, int length)Calculate a hash code of a byte array assuming ASCII character encoding. The resulting hash code will be case insensitive.- Parameters:
bytes- The array which contains the data to hash.startPos- What index to start generating a hash code inbyteslength- The amount of bytes that should be accounted for in the computation.- Returns:
- The hash code of
bytesassuming ASCII character encoding. The resulting hash code will be case insensitive.
-
hashCodeAscii
public static int hashCodeAscii(java.lang.CharSequence bytes)
Calculate a hash code of a byte array assuming ASCII character encoding. The resulting hash code will be case insensitive.This method assumes that
bytesis equivalent to abyte[]but just usingCharSequencefor storage. The upper most byte of eachcharfrombytesis ignored.- Parameters:
bytes- The array which contains the data to hash (assumed to be equivalent to abyte[]).- Returns:
- The hash code of
bytesassuming ASCII character encoding. The resulting hash code will be case insensitive.
-
newMpscQueue
public static <T> java.util.Queue<T> newMpscQueue()
Create a newQueuewhich is safe to use for multiple producers (different threads) and a single consumer (one thread!).- Returns:
- A MPSC queue which may be unbounded.
-
newMpscQueue
public static <T> java.util.Queue<T> newMpscQueue(int maxCapacity)
Create a newQueuewhich is safe to use for multiple producers (different threads) and a single consumer (one thread!).
-
newMpscQueue
public static <T> java.util.Queue<T> newMpscQueue(int chunkSize, int maxCapacity)Create a newQueuewhich is safe to use for multiple producers (different threads) and a single consumer (one thread!). The queue will grow and shrink its capacity in units of the given chunk size.
-
newSpscQueue
public static <T> java.util.Queue<T> newSpscQueue()
Create a newQueuewhich is safe to use for single producer (one thread!) and a single consumer (one thread!).
-
newFixedMpscQueue
public static <T> java.util.Queue<T> newFixedMpscQueue(int capacity)
Create a newQueuewhich is safe to use for multiple producers (different threads) and a single consumer (one thread!) with the given fixescapacity.
-
newFixedMpscUnpaddedQueue
public static <T> java.util.Queue<T> newFixedMpscUnpaddedQueue(int capacity)
Create a new un-paddedQueuewhich is safe to use for multiple producers (different threads) and a single consumer (one thread!) with the given fixescapacity.
This should be preferred tonewFixedMpscQueue(int)when the queue is not to be heavily contended.
-
newFixedMpmcQueue
public static <T> java.util.Queue<T> newFixedMpmcQueue(int capacity)
Create a newQueuewhich is safe to use for multiple producers (different threads) and multiple consumers with the given fixescapacity.
-
getClassLoader
public static java.lang.ClassLoader getClassLoader(java.lang.Class<?> clazz)
Return theClassLoaderfor the givenClass.
-
getContextClassLoader
public static java.lang.ClassLoader getContextClassLoader()
Return the contextClassLoaderfor the currentThread.
-
getSystemClassLoader
public static java.lang.ClassLoader getSystemClassLoader()
Return the systemClassLoader.
-
newConcurrentDeque
public static <C> java.util.Deque<C> newConcurrentDeque()
Returns a new concurrentDeque.
-
threadLocalRandom
@Deprecated public static java.util.Random threadLocalRandom()
Deprecated.Use ThreadLocalRandom.current() instead.Return aRandomwhich is not-threadsafe and so can only be used from the same thread.
-
isJ9Jvm
public static boolean isJ9Jvm()
-
isIkvmDotNet
public static boolean isIkvmDotNet()
-
estimateMaxDirectMemory
public static long estimateMaxDirectMemory()
Compute an estimate of the maximum amount of direct memory available to this JVM.The computation is not cached, so you probably want to use
maxDirectMemory()instead.This will produce debug log output when called.
- Returns:
- The estimated max direct memory, in bytes.
-
normalizedArch
public static java.lang.String normalizedArch()
-
normalizedOs
public static java.lang.String normalizedOs()
-
normalizedLinuxClassifiers
public static java.util.Set<java.lang.String> normalizedLinuxClassifiers()
-
createTempFile
public static java.io.File createTempFile(java.lang.String prefix, java.lang.String suffix, java.io.File directory) throws java.io.IOException- Throws:
java.io.IOException
-
isJfrEnabled
public static boolean isJfrEnabled()
Check if JFR events are supported on this platform.
-
-