Package io.netty.util.concurrent
Class FastThreadLocalThread
- java.lang.Object
-
- java.lang.Thread
-
- io.netty.util.concurrent.FastThreadLocalThread
-
- All Implemented Interfaces:
java.lang.Runnable
public class FastThreadLocalThread extends java.lang.Thread
A specialThread
that provides fast access toFastThreadLocal
variables.
-
-
Constructor Summary
Constructors Constructor Description FastThreadLocalThread()
FastThreadLocalThread(java.lang.Runnable target)
FastThreadLocalThread(java.lang.Runnable target, java.lang.String name)
FastThreadLocalThread(java.lang.String name)
FastThreadLocalThread(java.lang.ThreadGroup group, java.lang.Runnable target)
FastThreadLocalThread(java.lang.ThreadGroup group, java.lang.Runnable target, java.lang.String name)
FastThreadLocalThread(java.lang.ThreadGroup group, java.lang.Runnable target, java.lang.String name, long stackSize)
FastThreadLocalThread(java.lang.ThreadGroup group, java.lang.String name)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description static boolean
currentThreadHasFastThreadLocal()
Returnstrue
if this thread supportsFastThreadLocal
.static boolean
currentThreadWillCleanupFastThreadLocals()
boolean
permitBlockingCalls()
Query whether this thread is allowed to perform blocking calls or not.static void
runWithFastThreadLocal(java.lang.Runnable runnable)
Run the given task withFastThreadLocal
support.void
setThreadLocalMap(InternalThreadLocalMap threadLocalMap)
Sets the internal data structure that keeps the thread-local variables bound to this thread.InternalThreadLocalMap
threadLocalMap()
Returns the internal data structure that keeps the thread-local variables bound to this thread.boolean
willCleanupFastThreadLocals()
Deprecated.UsecurrentThreadWillCleanupFastThreadLocals()
insteadstatic boolean
willCleanupFastThreadLocals(java.lang.Thread thread)
Deprecated.UsecurrentThreadWillCleanupFastThreadLocals()
instead-
Methods inherited from class java.lang.Thread
activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, run, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield
-
-
-
-
Constructor Detail
-
FastThreadLocalThread
public FastThreadLocalThread()
-
FastThreadLocalThread
public FastThreadLocalThread(java.lang.Runnable target)
-
FastThreadLocalThread
public FastThreadLocalThread(java.lang.ThreadGroup group, java.lang.Runnable target)
-
FastThreadLocalThread
public FastThreadLocalThread(java.lang.String name)
-
FastThreadLocalThread
public FastThreadLocalThread(java.lang.ThreadGroup group, java.lang.String name)
-
FastThreadLocalThread
public FastThreadLocalThread(java.lang.Runnable target, java.lang.String name)
-
FastThreadLocalThread
public FastThreadLocalThread(java.lang.ThreadGroup group, java.lang.Runnable target, java.lang.String name)
-
FastThreadLocalThread
public FastThreadLocalThread(java.lang.ThreadGroup group, java.lang.Runnable target, java.lang.String name, long stackSize)
-
-
Method Detail
-
threadLocalMap
public final InternalThreadLocalMap threadLocalMap()
Returns the internal data structure that keeps the thread-local variables bound to this thread. Note that this method is for internal use only, and thus is subject to change at any time.
-
setThreadLocalMap
public final void setThreadLocalMap(InternalThreadLocalMap threadLocalMap)
Sets the internal data structure that keeps the thread-local variables bound to this thread. Note that this method is for internal use only, and thus is subject to change at any time.
-
willCleanupFastThreadLocals
@Deprecated public boolean willCleanupFastThreadLocals()
Deprecated.UsecurrentThreadWillCleanupFastThreadLocals()
instead
-
willCleanupFastThreadLocals
@Deprecated public static boolean willCleanupFastThreadLocals(java.lang.Thread thread)
Deprecated.UsecurrentThreadWillCleanupFastThreadLocals()
instead
-
currentThreadWillCleanupFastThreadLocals
public static boolean currentThreadWillCleanupFastThreadLocals()
-
currentThreadHasFastThreadLocal
public static boolean currentThreadHasFastThreadLocal()
Returnstrue
if this thread supportsFastThreadLocal
.
-
runWithFastThreadLocal
public static void runWithFastThreadLocal(java.lang.Runnable runnable)
Run the given task withFastThreadLocal
support. This call should wrap the runnable for any thread that is long-running enough to make treating it as aFastThreadLocalThread
reasonable, but that can't actually extend this class (e.g. because it's a virtual thread). Netty will use optimizations for recyclers and allocators as if this was aFastThreadLocalThread
.This method will clean up any
FastThreadLocal
s at the end, andcurrentThreadWillCleanupFastThreadLocals()
will returntrue
.At the moment,
FastThreadLocal
uses normalThreadLocal
as the backing storage here, but in the future this may be replaced with scoped values, if semantics can be preserved and performance is good.- Parameters:
runnable
- The task to run
-
permitBlockingCalls
public boolean permitBlockingCalls()
Query whether this thread is allowed to perform blocking calls or not.FastThreadLocalThread
s are often used in event-loops, where blocking calls are forbidden in order to prevent event-loop stalls, so this method returnsfalse
by default.Subclasses of
FastThreadLocalThread
can override this method if they are not meant to be used for running event-loops.- Returns:
false
, unless overriden by a subclass.
-
-