Concurrent — netty Architecture
Custom event executors and thread-aware data structures.
Entity Profile
Dependency Diagram
graph TD subdomain_CommonUtil_Concurrent["Concurrent"] 2dc2d6e5_c15a_8f05_f928_659448d21a9f["ConcurrentSkipListIntObjMultimap.java"] subdomain_CommonUtil_Concurrent --> 2dc2d6e5_c15a_8f05_f928_659448d21a9f 0bf56b8e_2e4a_3f63_6931_914327934433["FastThreadLocal.java"] subdomain_CommonUtil_Concurrent --> 0bf56b8e_2e4a_3f63_6931_914327934433 8b9f7299_bca5_33cf_05d0_d10886c0c9cb["PromiseTask.java"] subdomain_CommonUtil_Concurrent --> 8b9f7299_bca5_33cf_05d0_d10886c0c9cb 2719d086_31e2_e452_be70_06d7ebf4b1af["SucceededFuture.java"] subdomain_CommonUtil_Concurrent --> 2719d086_31e2_e452_be70_06d7ebf4b1af 453b645c_dedb_26be_8579_f9ad9b4084fe["SystemTicker.java"] subdomain_CommonUtil_Concurrent --> 453b645c_dedb_26be_8579_f9ad9b4084fe 7d0df4ec_0da6_2d25_a41b_55ab13f4e495["ThreadPerTaskExecutor.java"] subdomain_CommonUtil_Concurrent --> 7d0df4ec_0da6_2d25_a41b_55ab13f4e495 01692fca_8bd2_3bfd_fd39_c4f22ae9e53d["FastThreadLocalRunnable.java"] subdomain_CommonUtil_Concurrent --> 01692fca_8bd2_3bfd_fd39_c4f22ae9e53d c5aeb382_a779_97c9_ea1a_c7f2e0c1ec5d["BlockingOperationException.java"] subdomain_CommonUtil_Concurrent --> c5aeb382_a779_97c9_ea1a_c7f2e0c1ec5d 034febe8_bd47_5914_11b2_32e836f6c193["DefaultEventExecutor.java"] subdomain_CommonUtil_Concurrent --> 034febe8_bd47_5914_11b2_32e836f6c193 553612e1_e4b2_c7bc_4236_cde2274ee7aa["DefaultPromise.java"] subdomain_CommonUtil_Concurrent --> 553612e1_e4b2_c7bc_4236_cde2274ee7aa 307c0c07_b747_3ca8_7e17_a2d563f23ce3["MultithreadEventExecutorGroup.java"] subdomain_CommonUtil_Concurrent --> 307c0c07_b747_3ca8_7e17_a2d563f23ce3 5b01cb31_90fb_870b_6979_4749efe4f629["DefaultMockTicker.java"] subdomain_CommonUtil_Concurrent --> 5b01cb31_90fb_870b_6979_4749efe4f629 b64f70b1_1ecd_fc71_d0ac_3c49aebb5e9e["GlobalEventExecutor.java"] subdomain_CommonUtil_Concurrent --> b64f70b1_1ecd_fc71_d0ac_3c49aebb5e9e 0f39a674_7a79_67d3_7730_add75b8e1c7e["SingleThreadEventExecutor.java"] subdomain_CommonUtil_Concurrent --> 0f39a674_7a79_67d3_7730_add75b8e1c7e style subdomain_CommonUtil_Concurrent fill:#6366f1,stroke:#818cf8,color:#fff
Relationship Graph
Domain
Functions
- AbstractEventExecutor()
- AbstractScheduledEventExecutor()
- AbstractScheduledEventExecutor()
- AccountingThreadFactory()
- AutoScalingEventExecutorChooser()
- AutoScalingEventExecutorChooserFactory()
- AutoScalingState()
- AutoScalingUtilizationMetric()
- BlockingOperationException()
- CauseHolder()
- CompleteFuture()
- ConcurrentSkipListIntObjMultimap()
- DefaultEventExecutor()
- DefaultEventExecutorChooserFactory()
- DefaultEventExecutorGroup()
- DefaultFutureListeners()
- DefaultProgressivePromise()
- DefaultPromise()
- DefaultThreadFactory()
- DefaultThreadProperties()
- Entry()
- EventExecutor()
- EventExecutor()
- EventExecutor()
- EventExecutor()
- EventExecutor()
- EventExecutor()
- EventExecutor()
- EventExecutor()
- EventExecutor()
- EventExecutor()
- EventExecutor()
- EventExecutor()
- EventExecutorChooser()
- EventExecutorChooser()
- EventExecutorGroup()
- EventExecutorGroup()
- EventExecutorGroup()
- F()
- FailedFuture()
- FallbackThreadSet()
- FastThreadLocal()
- FastThreadLocalRunnable()
- FastThreadLocalThread()
- GenericEventExecutorChooser()
- GlobalEventExecutor()
- ImmediateEventExecutor()
- ImmediateExecutor()
- ImmediateProgressivePromise()
- ImmediatePromise()
- Index()
- IntEntry()
- InternalThreadLocalMap()
- Iter()
- MpscAtomicIntegerArrayQueue()
- MultithreadEventExecutorGroup()
- NetworkIfaceAndInetAddress()
- NetworkIfaceAndInetAddress()
- Node()
- NonNotifyRunnable()
- NonStickyEventExecutorGroup()
- NonStickyOrderedEventExecutor()
- NonStickyOrderedEventExecutor()
- Object()
- Object()
- PowerOfTwoEventExecutorChooser()
- PromiseAggregator()
- PromiseCombiner()
- PromiseNotifier()
- PromiseTask()
- ReferenceCountUtil()
- RejectedExecutionHandler()
- RejectedExecutionHandlers()
- ResourceLeakDetectorFactory()
- Runnable()
- Runnable()
- Runnable()
- Runnable()
- RunnableAdapter()
- RunnableScheduledFutureTask()
- ScheduledFutureTask()
- SentinelRunnable()
- SignalConstant()
- SingleThreadEventExecutor()
- StacklessCancellationException()
- State()
- String()
- String()
- String()
- String()
- String()
- String()
- String()
- StringBuilder()
- StringBuilder()
- StringBuilder()
- SucceededFuture()
- T()
- T()
- T()
- T()
- T()
- Thread()
- Thread()
- ThreadDeathWatcher()
- ThreadFactory()
- ThreadPerTaskExecutor()
- ThreadProperties()
- Throwable()
- Throwable()
- Throwable()
- Throwable()
- Throwable()
- Ticker()
- UnaryPromiseNotifier()
- UnorderedThreadPoolEventExecutor()
- V()
- V()
- V()
- V()
- V()
- V()
- V()
- V()
- V()
- acquireFence()
- acquireFenceFallback()
- activeExecutorCount()
- activeExecutorCount()
- add()
- add()
- add()
- addAll()
- addCount()
- addExclusions()
- addIndices()
- addListener()
- addListener()
- addListener()
- addListener0()
- addListeners()
- addListeners()
- addListeners()
- addShutdownHook()
- addTask()
- addTask()
- addToVariablesToRemove()
- advance()
- advance()
- afterRunningAllTasks()
- afterScheduledTaskSubmitted()
- await()
- await()
- await()
- await0()
- awaitInactivity()
- awaitInactivity()
- awaitSleepingThread()
- awaitTermination()
- awaitTermination()
- awaitTermination()
- awaitTermination()
- awaitTermination()
- awaitTermination()
- awaitUninterruptibly()
- awaitUninterruptibly()
- awaitUninterruptibly()
- baseHead()
- beforeScheduledTaskSubmitted()
- buildTimeMillis()
- canSuspend()
- cancel()
- cancel()
- cancel()
- cancel()
- cancelScheduledTasks()
- cancelWithoutRemove()
- cascadeTo()
- ceilingEntry()
- ceilingKey()
- checkAddAllowed()
- checkDeadLock()
- checkDeadLock()
- checkDeadLock()
- checkInEventLoop()
- checkNotifyWaiters()
- cleanup()
- clear()
- clearRefQueue()
- clearTaskAfterCompletion()
- cls()
- compareAndSetState()
- compareTo()
- compareTo()
- compareTo()
- compareTo()
- confirmShutdown()
- contains()
- containsKey()
- containsValue()
- cpr()
- currentThreadHasFastThreadLocal()
- currentThreadWillCleanupFastThreadLocals()
- customClassConstructor()
- deadlineNanos()
- deadlineNanos()
- deadlineNanos()
- deadlineToDelayNanos()
- deadlineToDelayNanos()
- decWaiters()
- decorateTask()
- defaultCurrentTimeNanos()
- delayNanos()
- delayNanos()
- delayNanos()
- destroy()
- doRemoveFirstEntry()
- doRemoveLastEntry()
- doStartThread()
- drain()
- drainTasks()
- ensureThreadStarted()
- equals()
- equals()
- equals()
- equals()
- execute()
- execute()
- execute()
- execute()
- execute()
- execute()
- execute()
- execute()
- execute()
- execute0()
- execute0()
- executeExpiredScheduledTasks()
- executorCount()
- executorUtilizations()
- executorUtilizations()
- fetchFromScheduledTaskQueue()
- fetchFromScheduledTaskQueue()
- fetchFromScheduledTaskQueue()
- fetchWatchees()
- fill()
- findFirst()
- findFirstEntry()
- findLast()
- findLastEntry()
- findNear()
- findNearEntry()
- findNode()
- findPredecessor()
- finish()
- firstEntry()
- firstKey()
- floorEntry()
- floorKey()
- forEach()
- getAdderCount()
- getAndIncrementBusyCycles()
- getAndIncrementIdleCycles()
- getAndResetAccumulatedActiveTimeNanos()
- getCurrentTimeNanos()
- getDelay()
- getDelay()
- getId()
- getKey()
- getLastActivityTimeNanos()
- getNumOfRegisteredChannels()
- hasNext()
- hasScheduledTasks()
- hasTasks()
- hashCode()
- hashCode()
- hashCode()
- higherEntry()
- higherKey()
- id()
- id()
- identify()
- inEventLoop()
- inEventLoop()
- inEventLoop()
- inEventLoop()
- inEventLoop()
- incWaiters()
- initialNanoTime()
- initialNanoTime()
- interruptThread()
- invokeAll()
- invokeAll()
- invokeAll()
- isAlive()
- isCancellable()
- isCancellable()
- isCancelled()
- isCancelled()
- isCancelled0()
- isDaemon()
- isDone()
- isDone()
- isDone0()
- isEmpty()
- isEmpty()
- isFastThreadLocalVirtualThread()
- isInterrupted()
- isNullOrEmpty()
- isPeriodic()
- isPowerOfTwo()
- isRecordEnabled()
- isSet()
- isShutdown()
- isShutdown()
- isShutdown()
- isShutdown()
- isShutdown()
- isShutdown()
- isShuttingDown()
- isShuttingDown()
- isShuttingDown()
- isShuttingDown()
- isShuttingDown()
- isShuttingDown()
- isShuttingDown()
- isSuccess()
- isSuccess()
- isSuccess()
- isSuspended()
- isSuspensionSupported()
- isTerminated()
- isTerminated()
- isTerminated()
- isTerminated()
- isTerminated()
- isTerminated()
- iterator()
- iterator()
- iterator()
- iterator()
- iterator()
- lastEntry()
- lastKey()
- lazyExecute()
- lazyExecute()
- lazyExecute0()
- listeners()
- lowerEntry()
- lowerKey()
- main()
- nanoTime()
- nanoTime()
- nanoTime()
- newFailedFuture()
- newProgressivePromise()
- newProgressivePromise()
- newPromise()
- newPromise()
- newSucceededFuture()
- newTaskFor()
- newTaskQueue()
- next()
- nextScheduledTaskDeadlineNanos()
- nextScheduledTaskNano()
- notifyListener()
- notifyListener0()
- notifyListenerWithStackOverFlowProtection()
- notifyListeners()
- notifyListeners0()
- notifyListenersNow()
- notifyProgressiveListener0()
- notifyProgressiveListeners()
- notifyProgressiveListeners0()
- obsoleteCustomClassConstructor()
- offer()
- offerTask()
- onRemoval()
- operationComplete()
- operationComplete()
- operationComplete()
- peekScheduledTask()
- pendingTasks()
- pendingTasks()
- permitBlockingCalls()
- poll()
- pollCeilingEntry()
- pollFirstEntry()
- pollLastEntry()
- priority()
- priorityQueueIndex()
- progressiveSize()
- put()
- reachabilityFence0()
- rebuildActiveExecutors()
- record0()
- reject()
- release()
- remove()
- remove()
- remove()
- remove()
- removeAll()
- removeFromVariablesToRemove()
- removeListener()
- removeListener()
- removeListener()
- removeListener0()
- removeListeners()
- removeListeners()
- removeListeners()
- removeScheduled()
- removeShutdownHook()
- removeTask()
- replace()
- replaceAll()
- reportActiveIoTime()
- reportLeak()
- reportUntracedLeak()
- resetBusyCycles()
- resetIdleCycles()
- rethrowIfFailed()
- run()
- run()
- run()
- run()
- run()
- run()
- run()
- run()
- run()
- run()
- run()
- run()
- runAllTasks()
- runAllTasksFrom()
- runExistingTasksFrom()
- runScheduledAndExecutorTasks()
- runShutdownHooks()
- runTask()
- runWithFastThreadLocal()
- safeExecute()
- safeExecute()
- safeRelease()
- schedule()
- schedule()
- schedule()
- schedule()
- schedule()
- scheduleAtFixedRate()
- scheduleAtFixedRate()
- scheduleAtFixedRate()
- scheduleAtFixedRate()
- scheduleAtFixedRate()
- scheduleFromEventLoop()
- scheduleRemoveScheduled()
- scheduleRemoveScheduled()
- scheduleWithFixedDelay()
- scheduleWithFixedDelay()
- scheduleWithFixedDelay()
- scheduleWithFixedDelay()
- scheduleWithFixedDelay()
- scheduledTaskQueue()
- set()
- setConsumed()
- setContextClassLoader()
- setEnabled()
- setFailure()
- setFailure()
- setFailure()
- setFailure0()
- setFailureInternal()
- setId()
- setProgress()
- setSuccess()
- setSuccess()
- setSuccess()
- setSuccess0()
- setSuccessInternal()
- setThreadLocalMap()
- setUncancellable()
- setUncancellable()
- setUncancellableInternal()
- setUtilization()
- setValue0()
- shutdown()
- shutdown()
- shutdown()
- shutdown()
- shutdown()
- shutdown()
- shutdown()
- shutdown()
- shutdown()
- shutdown0()
- shutdownGracefully()
- shutdownGracefully()
- shutdownGracefully()
- shutdownGracefully()
- shutdownGracefully()
- shutdownGracefully()
- shutdownGracefully()
- shutdownGracefully()
- shutdownGracefully()
- shutdownNow()
- shutdownNow()
- shutdownNow()
- shutdownNow()
- size()
- size()
- size()
- size()
- sleep()
- sleep()
- stackTrace()
- startThread()
- startThread()
- submit()
- submit()
- submit()
- submit()
- sync()
- sync()
- sync()
- sync()
- syncUninterruptibly()
- syncUninterruptibly()
- syncUninterruptibly()
- syncUninterruptibly()
- terminationFuture()
- terminationFuture()
- terminationFuture()
- terminationFuture()
- terminationFuture()
- terminationFuture()
- terminationFuture()
- threadLocalSize()
- throwIfInEventLoop()
- track()
- tryFailure()
- tryFailure()
- tryFailureInternal()
- tryProgress()
- tryPromise()
- tryReduceLevel()
- tryScaleUpBy()
- trySuccess()
- trySuccess()
- trySuccessInternal()
- trySuspend()
- unlinkNode()
- unwatch()
- updateLastExecutionTime()
- utilization()
- validatePeriod()
- validateScheduled()
- validateScheduled0()
- wakesUpForTask()
- wakeup()
- willCleanupFastThreadLocals()
Source Files
- common/src/main/java/io/netty/util/concurrent/AbstractEventExecutor.java
- common/src/main/java/io/netty/util/concurrent/AbstractEventExecutorGroup.java
- common/src/main/java/io/netty/util/concurrent/AbstractFuture.java
- common/src/main/java/io/netty/util/concurrent/AbstractScheduledEventExecutor.java
- common/src/main/java/io/netty/util/concurrent/AutoScalingEventExecutorChooserFactory.java
- common/src/main/java/io/netty/util/concurrent/BlockingOperationException.java
- common/src/main/java/io/netty/util/concurrent/CompleteFuture.java
- common/src/main/java/io/netty/util/concurrent/ConcurrentSkipListIntObjMultimap.java
- common/src/main/java/io/netty/util/concurrent/DefaultEventExecutor.java
- common/src/main/java/io/netty/util/concurrent/DefaultEventExecutorChooserFactory.java
- common/src/main/java/io/netty/util/concurrent/DefaultEventExecutorGroup.java
- common/src/main/java/io/netty/util/concurrent/DefaultFutureListeners.java
- common/src/main/java/io/netty/util/concurrent/DefaultMockTicker.java
- common/src/main/java/io/netty/util/concurrent/DefaultProgressivePromise.java
- common/src/main/java/io/netty/util/concurrent/DefaultPromise.java
- common/src/main/java/io/netty/util/concurrent/DefaultThreadFactory.java
- common/src/main/java/io/netty/util/concurrent/FailedFuture.java
- common/src/main/java/io/netty/util/concurrent/FastThreadLocal.java
- common/src/main/java/io/netty/util/concurrent/FastThreadLocalRunnable.java
- common/src/main/java/io/netty/util/concurrent/FastThreadLocalThread.java
- common/src/main/java/io/netty/util/concurrent/GlobalEventExecutor.java
- common/src/main/java/io/netty/util/concurrent/ImmediateEventExecutor.java
- common/src/main/java/io/netty/util/concurrent/ImmediateExecutor.java
- common/src/main/java/io/netty/util/concurrent/MpscIntQueue.java
- common/src/main/java/io/netty/util/concurrent/MultithreadEventExecutorGroup.java
- common/src/main/java/io/netty/util/concurrent/NonStickyEventExecutorGroup.java
- common/src/main/java/io/netty/util/concurrent/PromiseAggregator.java
- common/src/main/java/io/netty/util/concurrent/PromiseCombiner.java
- common/src/main/java/io/netty/util/concurrent/PromiseNotifier.java
- common/src/main/java/io/netty/util/concurrent/PromiseTask.java
- common/src/main/java/io/netty/util/ReferenceCountUtil.java
- common/src/main/java/io/netty/util/concurrent/RejectedExecutionHandlers.java
- common/src/main/java/io/netty/util/ResourceLeakDetector.java
- common/src/main/java/io/netty/util/ResourceLeakDetectorFactory.java
- common/src/main/java/io/netty/util/concurrent/ScheduledFutureTask.java
- common/src/main/java/io/netty/util/concurrent/SingleThreadEventExecutor.java
- common/src/main/java/io/netty/util/concurrent/SucceededFuture.java
- common/src/main/java/io/netty/util/concurrent/SystemTicker.java
- common/src/main/java/io/netty/util/concurrent/ThreadPerTaskExecutor.java
- common/src/main/java/io/netty/util/concurrent/UnaryPromiseNotifier.java
- common/src/main/java/io/netty/util/concurrent/UnorderedThreadPoolEventExecutor.java
- common/src/main/java/io/netty/util/Version.java
Source
- common/src/main/java/io/netty/util/concurrent/AbstractEventExecutor.java
- common/src/main/java/io/netty/util/concurrent/AbstractEventExecutorGroup.java
- common/src/main/java/io/netty/util/concurrent/AbstractFuture.java
- common/src/main/java/io/netty/util/concurrent/AbstractScheduledEventExecutor.java
- common/src/main/java/io/netty/util/concurrent/AutoScalingEventExecutorChooserFactory.java
- common/src/main/java/io/netty/util/concurrent/BlockingOperationException.java
- common/src/main/java/io/netty/util/concurrent/CompleteFuture.java
- common/src/main/java/io/netty/util/concurrent/ConcurrentSkipListIntObjMultimap.java
- common/src/main/java/io/netty/util/concurrent/DefaultEventExecutor.java
- common/src/main/java/io/netty/util/concurrent/DefaultEventExecutorChooserFactory.java
- common/src/main/java/io/netty/util/concurrent/DefaultEventExecutorGroup.java
- common/src/main/java/io/netty/util/concurrent/DefaultFutureListeners.java
- common/src/main/java/io/netty/util/concurrent/DefaultMockTicker.java
- common/src/main/java/io/netty/util/concurrent/DefaultProgressivePromise.java
- common/src/main/java/io/netty/util/concurrent/DefaultPromise.java
- common/src/main/java/io/netty/util/concurrent/DefaultThreadFactory.java
- common/src/main/java/io/netty/util/concurrent/FailedFuture.java
- common/src/main/java/io/netty/util/concurrent/FastThreadLocal.java
- common/src/main/java/io/netty/util/concurrent/FastThreadLocalRunnable.java
- common/src/main/java/io/netty/util/concurrent/FastThreadLocalThread.java
- common/src/main/java/io/netty/util/concurrent/GlobalEventExecutor.java
- common/src/main/java/io/netty/util/concurrent/ImmediateEventExecutor.java
- common/src/main/java/io/netty/util/concurrent/ImmediateExecutor.java
- common/src/main/java/io/netty/util/concurrent/MpscIntQueue.java
- common/src/main/java/io/netty/util/concurrent/MultithreadEventExecutorGroup.java
- common/src/main/java/io/netty/util/concurrent/NonStickyEventExecutorGroup.java
- common/src/main/java/io/netty/util/concurrent/PromiseAggregator.java
- common/src/main/java/io/netty/util/concurrent/PromiseCombiner.java
- common/src/main/java/io/netty/util/concurrent/PromiseNotifier.java
- common/src/main/java/io/netty/util/concurrent/PromiseTask.java
- common/src/main/java/io/netty/util/ReferenceCountUtil.java
- common/src/main/java/io/netty/util/concurrent/RejectedExecutionHandlers.java
- common/src/main/java/io/netty/util/ResourceLeakDetector.java
- common/src/main/java/io/netty/util/ResourceLeakDetectorFactory.java
- common/src/main/java/io/netty/util/concurrent/ScheduledFutureTask.java
- common/src/main/java/io/netty/util/concurrent/SingleThreadEventExecutor.java
- common/src/main/java/io/netty/util/concurrent/SucceededFuture.java
- common/src/main/java/io/netty/util/concurrent/SystemTicker.java
- common/src/main/java/io/netty/util/concurrent/ThreadPerTaskExecutor.java
- common/src/main/java/io/netty/util/concurrent/UnaryPromiseNotifier.java
- common/src/main/java/io/netty/util/concurrent/UnorderedThreadPoolEventExecutor.java
- common/src/main/java/io/netty/util/Version.java
Frequently Asked Questions
What is the Concurrent subdomain?
Concurrent is a subdomain in the netty codebase, part of the CommonUtil domain. Custom event executors and thread-aware data structures. It contains 42 source files.
Which domain does Concurrent belong to?
Concurrent belongs to the CommonUtil domain.
What functions are in Concurrent?
The Concurrent subdomain contains 560 function(s): AbstractEventExecutor, AbstractScheduledEventExecutor, AbstractScheduledEventExecutor, AccountingThreadFactory, AutoScalingEventExecutorChooser, AutoScalingEventExecutorChooserFactory, AutoScalingState, AutoScalingUtilizationMetric, and 552 more.
Analyze Your Own Codebase
Get architecture documentation, dependency graphs, and domain analysis for your codebase in minutes.
Try Supermodel Free