| Modifier and Type | Class and Description |
|---|---|
| pack-priv static class |
| Modifier and Type | Field and Description |
|---|---|
| private static final int | |
| private static final ThreadLocal |
| Access | Constructor and Description |
|---|---|
| private |
| Modifier and Type | Method and Description |
|---|---|
| pack-priv static void | |
| pack-priv static Invoker. | |
| pack-priv static <V, A> void | invoke(AsynchronousChannel channel, CompletionHandler<V, ? super A> handler, A attachment, V result, Throwable exc)
Invokes the handler. |
| pack-priv static <V, A> void | |
| pack-priv static <V, A> void | invokeDirect(Invoker.
Invoke handler assuming thread identity already checked |
| pack-priv static <V, A> void | invokeIndirectly(AsynchronousChannel channel, final CompletionHandler<V, ? super A> handler, final A attachment, final V result, final Throwable exc)
Invokes the handler indirectly via the channel group's thread pool. |
| pack-priv static <V, A> void | invokeIndirectly(final CompletionHandler<V, ? super A> handler, final A attachment, final V value, final Throwable exc, Executor executor)
Invokes the handler "indirectly" in the given Executor |
| pack-priv static <V, A> void | |
| pack-priv static void | invokeOnThreadInThreadPool(Groupable channel, Runnable task)
Invokes the given task on the thread pool associated with the given channel. |
| pack-priv static <V, A> void | invokeUnchecked(CompletionHandler<V, ? super A> handler, A attachment, V value, Throwable exc)
Invoke handler without checking the thread identity or number of handlers on the thread stack. |
| pack-priv static <V, A> void | |
| pack-priv static boolean | |
| pack-priv static boolean | mayInvokeDirect(Invoker.
Returns true if the current thread is in the given channel's thread pool and we haven't exceeded the maximum number of handler frames on the stack. |
| maxHandlerInvokeCount | back to summary |
|---|---|
| private static final int maxHandlerInvokeCount | |
| myGroupAndInvokeCount | back to summary |
|---|---|
| private static final ThreadLocal<Invoker. | |
| Invoker | back to summary |
|---|---|
| private Invoker() | |
| bindToGroup | back to summary |
|---|---|
| pack-priv static void bindToGroup(AsynchronousChannelGroupImpl group) Binds this thread to the given group | |
| getGroupAndInvokeCount | back to summary |
|---|---|
| pack-priv static Invoker. Returns the GroupAndInvokeCount object for this thread. | |
| invoke | back to summary |
|---|---|
| pack-priv static <V, A> void invoke(AsynchronousChannel channel, CompletionHandler<V, ? super A> handler, A attachment, V result, Throwable exc) Invokes the handler. If the current thread is in the channel group's thread pool then the handler is invoked directly, otherwise it is invoked indirectly. | |
| invoke | back to summary |
|---|---|
| pack-priv static <V, A> void invoke(PendingFuture<V, A> future) Invoke handler with completed result. If the current thread is in the channel group's thread pool then the handler is invoked directly, otherwise it is invoked indirectly. | |
| invokeDirect | back to summary |
|---|---|
| pack-priv static <V, A> void invokeDirect(Invoker. Invoke handler assuming thread identity already checked | |
| invokeIndirectly | back to summary |
|---|---|
| pack-priv static <V, A> void invokeIndirectly(AsynchronousChannel channel, final CompletionHandler<V, ? super A> handler, final A attachment, final V result, final Throwable exc) Invokes the handler indirectly via the channel group's thread pool. | |
| invokeIndirectly | back to summary |
|---|---|
| pack-priv static <V, A> void invokeIndirectly(final CompletionHandler<V, ? super A> handler, final A attachment, final V value, final Throwable exc, Executor executor) Invokes the handler "indirectly" in the given Executor | |
| invokeIndirectly | back to summary |
|---|---|
| pack-priv static <V, A> void invokeIndirectly(PendingFuture<V, A> future) Invoke handler with completed result. The handler is invoked indirectly, via the channel group's thread pool. | |
| invokeOnThreadInThreadPool | back to summary |
|---|---|
| pack-priv static void invokeOnThreadInThreadPool(Groupable channel, Runnable task) Invokes the given task on the thread pool associated with the given channel. If the current thread is in the thread pool then the task is invoked directly. | |
| invokeUnchecked | back to summary |
|---|---|
| pack-priv static <V, A> void invokeUnchecked(CompletionHandler<V, ? super A> handler, A attachment, V value, Throwable exc) Invoke handler without checking the thread identity or number of handlers on the thread stack. | |
| invokeUnchecked | back to summary |
|---|---|
| pack-priv static <V, A> void invokeUnchecked(PendingFuture<V, A> future) Invoke handler with completed result. This method does not check the thread identity or the number of handlers on the thread stack. | |
| isBoundToAnyGroup | back to summary |
|---|---|
| pack-priv static boolean isBoundToAnyGroup() Returns true if the current thread is in a channel group's thread pool | |
| mayInvokeDirect | back to summary |
|---|---|
| pack-priv static boolean mayInvokeDirect(Invoker. Returns true if the current thread is in the given channel's thread pool and we haven't exceeded the maximum number of handler frames on the stack. | |
| Modifier and Type | Field and Description |
|---|---|
| private final AsynchronousChannelGroupImpl | |
| private int |
| Access | Constructor and Description |
|---|---|
| pack-priv |
| Modifier and Type | Method and Description |
|---|---|
| pack-priv AsynchronousChannelGroupImpl | |
| pack-priv void | |
| pack-priv int | |
| pack-priv void | |
| pack-priv void |
| group | back to summary |
|---|---|
| private final AsynchronousChannelGroupImpl group | |
| handlerInvokeCount | back to summary |
|---|---|
| private int handlerInvokeCount | |
| GroupAndInvokeCount | back to summary |
|---|---|
| pack-priv GroupAndInvokeCount(AsynchronousChannelGroupImpl group) | |
| group | back to summary |
|---|---|
| pack-priv AsynchronousChannelGroupImpl group() | |
| incrementInvokeCount | back to summary |
|---|---|
| pack-priv void incrementInvokeCount() | |
| invokeCount | back to summary |
|---|---|
| pack-priv int invokeCount() | |
| resetInvokeCount | back to summary |
|---|---|
| pack-priv void resetInvokeCount() | |
| setInvokeCount | back to summary |
|---|---|
| pack-priv void setInvokeCount(int value) | |