io.openmessaging.joyqueue.producer.support

类 FutureAdapter<V>

java.lang.Object

io.openmessaging.joyqueue.producer.support.FutureAdapter<V>

所有已实现的接口:

io.openmessaging.Future<V>

public class FutureAdapter<V>
extends Object
implements io.openmessaging.Future<V>

FutureAdapter author: gaohaoxiang date: 2019/2/20

构造器概要

构造器

构造器和说明
FutureAdapter()

方法概要

限定符和类型	方法和说明
void	addListener(io.openmessaging.FutureListener listener)
boolean	cancel(boolean mayInterruptIfRunning)
protected void	doNotify()
V	get()
V	get(long timeout)
Throwable	getThrowable()
protected V	getValue()
boolean	isCancelled()
boolean	isDone()
void	setThrowable(Throwable throwable)
void	setValue(Object value)

从类继承的方法 java.lang.Object

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

构造器详细资料

FutureAdapter

public FutureAdapter()

方法详细资料

setThrowable

public void setThrowable(Throwable throwable)

setValue

public void setValue(Object value)

getValue

protected V getValue()

doNotify

protected void doNotify()

cancel

public boolean cancel(boolean mayInterruptIfRunning)

指定者:

cancel 在接口中 io.openmessaging.Future<V>

isCancelled

public boolean isCancelled()

指定者:

isCancelled 在接口中 io.openmessaging.Future<V>

isDone

public boolean isDone()

指定者:

isDone 在接口中 io.openmessaging.Future<V>

get

public V get()

指定者:

get 在接口中 io.openmessaging.Future<V>

get

public V get(long timeout)

指定者:

get 在接口中 io.openmessaging.Future<V>

addListener

public void addListener(io.openmessaging.FutureListener listener)

指定者:

addListener 在接口中 io.openmessaging.Future<V>

getThrowable

public Throwable getThrowable()

指定者:

getThrowable 在接口中 io.openmessaging.Future<V>