Lines Matching defs:handler
34 * Defines static methods to invoke a completion handler or arbitrary task.
101 * pool and we haven't exceeded the maximum number of handler frames on
117 * Invoke handler without checking the thread identity or number of handlers
120 static <V,A> void invokeUnchecked(CompletionHandler<V,? super A> handler,
126 handler.completed(value, attachment);
128 handler.failed(exc, attachment);
136 * Invoke handler assuming thread identity already checked
139 CompletionHandler<V,? super A> handler,
145 Invoker.invokeUnchecked(handler, attachment, result, exc);
149 * Invokes the handler. If the current thread is in the channel group's
150 * thread pool then the handler is invoked directly, otherwise it is
154 CompletionHandler<V,? super A> handler,
173 invokeDirect(thisGroupAndInvokeCount, handler, attachment, result, exc);
176 invokeIndirectly(channel, handler, attachment, result, exc);
182 handler, attachment, result, exc);
191 * Invokes the handler indirectly via the channel group's thread pool.
194 final CompletionHandler<V,? super A> handler,
206 invokeUnchecked(handler, attachment, result, exc);
215 * Invokes the handler "indirectly" in the given Executor
217 static <V,A> void invokeIndirectly(final CompletionHandler<V,? super A> handler,
226 invokeUnchecked(handler, attachment, value, exc);
262 * Invoke handler with completed result. This method does not check the
267 CompletionHandler<V,? super A> handler = future.handler();
268 if (handler != null) {
269 invokeUnchecked(handler,
277 * Invoke handler with completed result. If the current thread is in the
278 * channel group's thread pool then the handler is invoked directly,
283 CompletionHandler<V,? super A> handler = future.handler();
284 if (handler != null) {
286 handler,
294 * Invoke handler with completed result. The handler is invoked indirectly,
299 CompletionHandler<V,? super A> handler = future.handler();
300 if (handler != null) {
302 handler,