Grizzly NIO 5.0.2 · org.glassfish.grizzly.impl.UnsafeFutureImpl

Modifier and Type	Field and Description
private static final ThreadCache.CachedTypeIndex<UnsafeFutureImpl<R>>	CACHE_IDX
protected Set<CompletionHandler<R>>	completionHandlers
protected Throwable	failure
protected boolean	isCancelled
protected boolean	isDone
protected int	recycleMark
protected R	result

Access	Constructor and Description
private	UnsafeFutureImpl()

Method Summary

Modifier and Type	Method and Description
public void	addCompletionHandler(final CompletionHandler<R> completionHandler) Implements org.glassfish.grizzly.GrizzlyFuture.addCompletionHandler. Adds a `CompletionHandler`, which will be notified once the asynchronous computation, represented by this `Future`, is complete.
public boolean	cancel(boolean mayInterruptIfRunning) Implements java.util.concurrent.Future.cancel. Attempts to cancel execution of this task.
public static <R> UnsafeFutureImpl<R>	create() Construct `Future`.
public void	failure(Throwable failure) Implements org.glassfish.grizzly.impl.FutureImpl.failure. Notify about the failure, occurred during asynchronous operation execution.
public R	get() Implements java.util.concurrent.Future.get. Waits if necessary for the computation to complete, and then retrieves its result.
public R	get(long timeout, TimeUnit unit) Implements java.util.concurrent.Future.get. Waits if necessary for at most the given time for the computation to complete, and then retrieves its result, if available.
public R	Returns: current result value without any blocking. getResult() Implements org.glassfish.grizzly.impl.FutureImpl.getResult. Get current result value without any blocking.
public boolean	isCancelled() Implements java.util.concurrent.Future.isCancelled. Returns `true` if this task was cancelled before it completed normally.
public boolean	isDone() Implements java.util.concurrent.Future.isDone. Returns `true` if this task completed.
public void	markForRecycle(boolean recycleResult) Implements org.glassfish.grizzly.GrizzlyFuture.markForRecycle. Mark `GrizzlyFuture` as recyclable, so once result will come - `GrizzlyFuture` object will be recycled and returned to a thread local object pool.
private void	notifyCompletionHandler(final CompletionHandler<R> completionHandler) Notify single `CompletionHandler` about the result.
private void	notifyCompletionHandlers() Notify registered `CompletionHandler`s about the result.
protected void	notifyHaveResult() Notify blocked listeners threads about operation completion.
public void	recycle(boolean recycleResult) Implements org.glassfish.grizzly.GrizzlyFuture.recycle. Recycle `GrizzlyFuture` now.
public void	recycle() Implements org.glassfish.grizzly.Cacheable.recycle.
protected void	reset()
public void	result(R the result value result) Implements org.glassfish.grizzly.impl.FutureImpl.result. Set the result value and notify about operation completion.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

CACHE_IDX	back to summary
private static final ThreadCache.CachedTypeIndex<UnsafeFutureImpl<R>> CACHE_IDX

completionHandlers	back to summary
protected Set<CompletionHandler<R>> completionHandlers

failure	back to summary
protected Throwable failure

isCancelled	back to summary
protected boolean isCancelled

isDone	back to summary
protected boolean isDone

recycleMark	back to summary
protected int recycleMark

result	back to summary
protected R result

UnsafeFutureImpl	back to summary
private UnsafeFutureImpl()

Method Detail

addCompletionHandler back to summary

addCompletionHandler	back to summary
public void addCompletionHandler(final CompletionHandler<R> completionHandler) Implements org.glassfish.grizzly.GrizzlyFuture.addCompletionHandler. Doc from org.glassfish.grizzly.GrizzlyFuture.addCompletionHandler. Adds a `CompletionHandler`, which will be notified once the asynchronous computation, represented by this `Future`, is complete. Annotations @Override

public void addCompletionHandler(final CompletionHandler<R> completionHandler)

Implements org.glassfish.grizzly.GrizzlyFuture.addCompletionHandler.

Doc from org.glassfish.grizzly.GrizzlyFuture.addCompletionHandler.

Adds a CompletionHandler, which will be notified once the asynchronous computation, represented by this Future, is complete.

Annotations

@Override

cancel back to summary

cancel	back to summary
public boolean cancel(boolean mayInterruptIfRunning) Implements java.util.concurrent.Future.cancel. Doc from java.util.concurrent.Future.cancel. Attempts to cancel execution of this task. This method has no effect if the task is already completed or cancelled, or could not be cancelled for some other reason. Otherwise, if this task has not started when `cancel` is called, this task should never run. If the task has already started, then the `mayInterruptIfRunning` parameter determines whether the thread executing this task (when known by the implementation) is interrupted in an attempt to stop the task. The return value from this method does not necessarily indicate whether the task is now cancelled; use `isCancelled`. Annotations @Override

public boolean cancel(boolean mayInterruptIfRunning)

Implements java.util.concurrent.Future.cancel.

Doc from java.util.concurrent.Future.cancel.

Attempts to cancel execution of this task. This method has no effect if the task is already completed or cancelled, or could not be cancelled for some other reason. Otherwise, if this task has not started when cancel is called, this task should never run. If the task has already started, then the mayInterruptIfRunning parameter determines whether the thread executing this task (when known by the implementation) is interrupted in an attempt to stop the task.

The return value from this method does not necessarily indicate whether the task is now cancelled; use isCancelled.

Annotations

@Override

create back to summary

create	back to summary
public static <R> UnsafeFutureImpl<R> create() Construct `Future`. Annotations @SuppressWarnings:unchecked

public static <R> UnsafeFutureImpl<R> create()

Construct Future.

Annotations

@SuppressWarnings:unchecked

failure	back to summary
public void failure(Throwable failure) Implements org.glassfish.grizzly.impl.FutureImpl.failure. Notify about the failure, occurred during asynchronous operation execution. Annotations @Override

failure

back to summary

public void failure(Throwable failure)

Implements org.glassfish.grizzly.impl.FutureImpl.failure.

Notify about the failure, occurred during asynchronous operation execution.

Annotations

@Override

get	back to summary
public R get() throws InterruptedException, ExecutionException Implements java.util.concurrent.Future.get. Doc from java.util.concurrent.Future.get. Waits if necessary for the computation to complete, and then retrieves its result. Annotations @Override Exceptions InterruptedException: if the current thread was interrupted while waiting ExecutionException: if the computation threw an exception

get

back to summary

public R get() throws InterruptedException, ExecutionException

Implements java.util.concurrent.Future.get.

Doc from java.util.concurrent.Future.get.

Waits if necessary for the computation to complete, and then retrieves its result.

Annotations

@Override

Exceptions

InterruptedException:: if the current thread was interrupted while waiting
ExecutionException:: if the computation threw an exception

get	back to summary
public R get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException Implements java.util.concurrent.Future.get. Doc from java.util.concurrent.Future.get. Waits if necessary for at most the given time for the computation to complete, and then retrieves its result, if available. Annotations @Override Exceptions InterruptedException: if the current thread was interrupted while waiting ExecutionException: if the computation threw an exception TimeoutException: if the wait timed out

get

back to summary

public R get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException

Implements java.util.concurrent.Future.get.

Doc from java.util.concurrent.Future.get.

Waits if necessary for at most the given time for the computation to complete, and then retrieves its result, if available.

Annotations

@Override

Exceptions

InterruptedException:: if the current thread was interrupted while waiting
ExecutionException:: if the computation threw an exception
TimeoutException:: if the wait timed out

getResult	back to summary
public R getResult() Implements org.glassfish.grizzly.impl.FutureImpl.getResult. Get current result value without any blocking. Returns:R current result value without any blocking. Annotations @Override

getResult

back to summary

public R getResult()

Implements org.glassfish.grizzly.impl.FutureImpl.getResult.

Get current result value without any blocking.

Returns:R

current result value without any blocking.

Annotations

@Override

isCancelled back to summary

isCancelled	back to summary
public boolean isCancelled() Implements java.util.concurrent.Future.isCancelled. Doc from java.util.concurrent.Future.isCancelled. Returns `true` if this task was cancelled before it completed normally. Annotations @Override

public boolean isCancelled()

Implements java.util.concurrent.Future.isCancelled.

Doc from java.util.concurrent.Future.isCancelled.

Returns true if this task was cancelled before it completed normally.

Annotations

@Override

isDone back to summary

isDone	back to summary
public boolean isDone() Implements java.util.concurrent.Future.isDone. Doc from java.util.concurrent.Future.isDone. Returns `true` if this task completed. Completion may be due to normal termination, an exception, or cancellation -- in all of these cases, this method will return `true`. Annotations @Override

public boolean isDone()

Implements java.util.concurrent.Future.isDone.

Doc from java.util.concurrent.Future.isDone.

Returns true if this task completed. Completion may be due to normal termination, an exception, or cancellation -- in all of these cases, this method will return true.

Annotations

@Override

markForRecycle back to summary

markForRecycle	back to summary
public void markForRecycle(boolean recycleResult) Implements org.glassfish.grizzly.GrizzlyFuture.markForRecycle. Doc from org.glassfish.grizzly.GrizzlyFuture.markForRecycle. Mark `GrizzlyFuture` as recyclable, so once result will come - `GrizzlyFuture` object will be recycled and returned to a thread local object pool. You can consider to use this method, if you're not interested in using this `GrizzlyFuture` object. Annotations @Override

public void markForRecycle(boolean recycleResult)

Implements org.glassfish.grizzly.GrizzlyFuture.markForRecycle.

Doc from org.glassfish.grizzly.GrizzlyFuture.markForRecycle.

Mark GrizzlyFuture as recyclable, so once result will come - GrizzlyFuture object will be recycled and returned to a thread local object pool. You can consider to use this method, if you're not interested in using this GrizzlyFuture object.

Annotations

@Override

notifyCompletionHandler	back to summary
private void notifyCompletionHandler(final CompletionHandler<R> completionHandler) Notify single `CompletionHandler` about the result.

notifyCompletionHandlers	back to summary
private void notifyCompletionHandlers() Notify registered `CompletionHandler`s about the result.

notifyHaveResult	back to summary
protected void notifyHaveResult() Notify blocked listeners threads about operation completion.

recycle back to summary

recycle	back to summary
public void recycle(boolean recycleResult) Implements org.glassfish.grizzly.GrizzlyFuture.recycle. Doc from org.glassfish.grizzly.GrizzlyFuture.recycle. Recycle `GrizzlyFuture` now. This method could be used, if you're not interested in using this `GrizzlyFuture` object, and you're sure this object is not used by any other application part. Annotations @Override

public void recycle(boolean recycleResult)

Implements org.glassfish.grizzly.GrizzlyFuture.recycle.

Doc from org.glassfish.grizzly.GrizzlyFuture.recycle.

Recycle GrizzlyFuture now. This method could be used, if you're not interested in using this GrizzlyFuture object, and you're sure this object is not used by any other application part.

Annotations

@Override

recycle	back to summary
public void recycle() Implements org.glassfish.grizzly.Cacheable.recycle. Annotations @Override

recycle

back to summary

public void recycle()

Implements org.glassfish.grizzly.Cacheable.recycle.

Annotations

@Override

reset	back to summary
protected void reset()

result	back to summary
public void result(R result) Implements org.glassfish.grizzly.impl.FutureImpl.result. Set the result value and notify about operation completion. Parameters result:R the result value Annotations @Override

result

back to summary

public void result(R result)

Implements org.glassfish.grizzly.impl.FutureImpl.result.

Set the result value and notify about operation completion.

Parameters

result:R: the result value

Annotations

@Override

public final Class UnsafeFutureImpl<R>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail