com.jrockit.memleak.mlp
Class AbstractMemLeak.ReqProcessor<T>

java.lang.Object
  com.jrockit.memleak.mlp.AbstractMemLeak.ReqProcessor<T>

Type Parameters:

T -

All Implemented Interfaces:

java.util.concurrent.Future<T>

Direct Known Subclasses:

MemLeakR28.GetClassesR28

Enclosing class:

AbstractMemLeak

protected abstract class AbstractMemLeak.ReqProcessor<T>
extends java.lang.Object
implements java.util.concurrent.Future<T>

Author:

mpersson

Field Summary

protected com.jrockit.memleak.mlp.ServerRequest

req

Constructor Summary

AbstractMemLeak.ReqProcessor(RequestType reqType)

Method Summary

boolean	cancel(boolean mayInterruptIfRunning)
T	get()
T	get(long timeout, java.util.concurrent.TimeUnit unit)
boolean	isCancelled()
boolean	isDone()
protected abstract T	parseResponse(java.io.DataInputStream dis)
AbstractMemLeak.ReqProcessor<T>	send()
java.util.concurrent.Future<T>	sendIfSupported() If this request is unsupported, returns a Future result of null, otherwise return as send().

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

req

protected com.jrockit.memleak.mlp.ServerRequest req

Constructor Detail

AbstractMemLeak.ReqProcessor

public AbstractMemLeak.ReqProcessor(RequestType reqType)

Parameters:

reqType -

Method Detail

send

public AbstractMemLeak.ReqProcessor<T> send()

Returns:

ReqProcessor<T> (implements Future<T>)

sendIfSupported

public java.util.concurrent.Future<T> sendIfSupported()

If this request is unsupported, returns a Future result of null, otherwise return as send().

Returns:

Future<T>

See Also:

send()

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface java.util.concurrent.Future<T>

get

public T get()
      throws java.util.concurrent.ExecutionException

Specified by:

get in interface java.util.concurrent.Future<T>

Throws:

java.util.concurrent.ExecutionException

parseResponse

protected abstract T parseResponse(java.io.DataInputStream dis)
                            throws GarbageCollectedException,
                                   SpiException,
                                   java.io.IOException

Parameters:

dis -

Returns:

T

Throws:

GarbageCollectedException

SpiException

java.io.IOException

get

public T get(long timeout,
             java.util.concurrent.TimeUnit unit)
      throws java.lang.InterruptedException,
             java.util.concurrent.ExecutionException,
             java.util.concurrent.TimeoutException

Specified by:

get in interface java.util.concurrent.Future<T>

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

java.util.concurrent.TimeoutException

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface java.util.concurrent.Future<T>

isDone

public boolean isDone()

Specified by:

isDone in interface java.util.concurrent.Future<T>