com.tencent.qcloud.core.task

类 QCloudTask<T>

java.lang.Object

com.tencent.qcloud.core.task.QCloudTask<T>

所有已实现的接口:

java.util.concurrent.Callable<T>

直接已知子类:

HttpTask

public abstract class QCloudTask<T>
extends java.lang.Object
implements java.util.concurrent.Callable<T>

嵌套类概要

嵌套类

限定符和类型	类和说明
static interface	QCloudTask.OnRequestWeightListener

字段概要

字段

限定符和类型	字段和说明
static int	PRIORITY_HIGH
static int	PRIORITY_LOW
protected static int	PRIORITY_NORMAL
static int	STATE_COMPLETE
static int	STATE_EXECUTING
static int	STATE_QUEUEING
static int	WEIGHT_HIGH
static int	WEIGHT_LOW
static int	WEIGHT_NORMAL

构造器概要

构造器

构造器和说明
QCloudTask(java.lang.String identifier, java.lang.Object tag)

方法概要

限定符和类型	方法和说明
QCloudTask<T>	addProgressListener(QCloudProgressListener progressListener)
QCloudTask<T>	addProgressListeners(java.util.List<QCloudProgressListener> progressListeners)
QCloudTask<T>	addResultListener(QCloudResultListener<T> resultListener)
QCloudTask<T>	addResultListeners(java.util.List<QCloudResultListener<T>> resultListeners)
QCloudTask<T>	addStateListener(QCloudTaskStateListener stateListener)
QCloudTask<T>	addStateListeners(java.util.List<QCloudTaskStateListener> stateListeners)
T	call() Computes a result, or throws an exception if unable to do so.
void	cancel()
bolts.Task<T>	cast()
protected abstract T	execute()
T	executeNow()
void	executeNowSilently()
java.util.List<QCloudProgressListener>	getAllProgressListeners()
java.util.List<QCloudResultListener<T>>	getAllResultListeners()
java.util.List<QCloudTaskStateListener>	getAllStateListeners()
int	getDownloadMaxThreadCount()
java.lang.Exception	getException()
java.lang.String	getIdentifier()
T	getResult()
int	getState() 获取任务执行状态
java.lang.Object	getTag()
int	getUploadMaxThreadCount()
int	getWeight()
boolean	isCanceled() 任务是否已经取消
boolean	isCompleted() 任务是否执行完成
boolean	isEnableTraffic()
boolean	isExecuting() 任务是否正在执行
QCloudTask<T>	observeOn(java.util.concurrent.Executor executor)
protected void	onFailure()
protected void	onProgress(long complete, long target)
protected void	onStateChanged(int newState)
protected void	onSuccess()
void	removeAllListeners()
QCloudTask<T>	removeProgressListener(QCloudProgressListener progressListener)
QCloudTask<T>	removeResultListener(QCloudResultListener<T> resultListener)
QCloudTask<T>	removeStateListener(QCloudTaskStateListener stateListener)
protected QCloudTask<T>	scheduleOn(java.util.concurrent.Executor executor, bolts.CancellationTokenSource cancellationTokenSource)
protected QCloudTask<T>	scheduleOn(java.util.concurrent.Executor executor, bolts.CancellationTokenSource cancellationTokenSource, int priority)
void	setDownloadMaxThreadCount(int downloadMaxThreadCount)
void	setOnRequestWeightListener(QCloudTask.OnRequestWeightListener onRequestWeightListener)
void	setTransferThreadControl(boolean enableTraffic)
void	setUploadMaxThreadCount(int uploadMaxThreadCount)

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

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

字段详细资料

STATE_QUEUEING

public static final int STATE_QUEUEING

另请参阅:

常量字段值

STATE_EXECUTING

public static final int STATE_EXECUTING

另请参阅:

常量字段值

STATE_COMPLETE

public static final int STATE_COMPLETE

另请参阅:

常量字段值

PRIORITY_LOW

public static final int PRIORITY_LOW

另请参阅:

常量字段值

PRIORITY_NORMAL

protected static final int PRIORITY_NORMAL

另请参阅:

常量字段值

PRIORITY_HIGH

public static final int PRIORITY_HIGH

另请参阅:

常量字段值

WEIGHT_LOW

public static final int WEIGHT_LOW

另请参阅:

常量字段值

WEIGHT_NORMAL

public static final int WEIGHT_NORMAL

另请参阅:

常量字段值

WEIGHT_HIGH

public static final int WEIGHT_HIGH

另请参阅:

常量字段值

构造器详细资料

QCloudTask

public QCloudTask(java.lang.String identifier,
                  java.lang.Object tag)

方法详细资料

cast

public final bolts.Task<T> cast()

executeNow

public final T executeNow()
                   throws QCloudClientException,
                          QCloudServiceException

抛出:

QCloudClientException

QCloudServiceException

executeNowSilently

public final void executeNowSilently()

scheduleOn

protected QCloudTask<T> scheduleOn(java.util.concurrent.Executor executor,
                                   bolts.CancellationTokenSource cancellationTokenSource)

scheduleOn

protected QCloudTask<T> scheduleOn(java.util.concurrent.Executor executor,
                                   bolts.CancellationTokenSource cancellationTokenSource,
                                   int priority)

cancel

public void cancel()

setTransferThreadControl

public void setTransferThreadControl(boolean enableTraffic)

isEnableTraffic

public boolean isEnableTraffic()

getUploadMaxThreadCount

public int getUploadMaxThreadCount()

setUploadMaxThreadCount

public void setUploadMaxThreadCount(int uploadMaxThreadCount)

getDownloadMaxThreadCount

public int getDownloadMaxThreadCount()

setDownloadMaxThreadCount

public void setDownloadMaxThreadCount(int downloadMaxThreadCount)

isCanceled

public final boolean isCanceled()

任务是否已经取消

返回:

true 表示任务已取消

isExecuting

public final boolean isExecuting()

任务是否正在执行

返回:

true 表示正在执行

isCompleted

public final boolean isCompleted()

任务是否执行完成

返回:

true 表示完成

getState

public final int getState()

获取任务执行状态

返回:

任务状态，，有以下几种状态： STATE_QUEUEING; STATE_EXECUTING; STATE_COMPLETE

call

public T call()
       throws java.lang.Exception

从接口复制的说明: java.util.concurrent.Callable

Computes a result, or throws an exception if unable to do so.

指定者:

call 在接口中 java.util.concurrent.Callable<T>

返回:

computed result

抛出:

java.lang.Exception - if unable to compute a result

execute

protected abstract T execute()
                      throws QCloudClientException,
                             QCloudServiceException

抛出:

QCloudClientException

QCloudServiceException

observeOn

public final QCloudTask<T> observeOn(java.util.concurrent.Executor executor)

addResultListener

public final QCloudTask<T> addResultListener(QCloudResultListener<T> resultListener)

addResultListeners

public final QCloudTask<T> addResultListeners(java.util.List<QCloudResultListener<T>> resultListeners)

removeResultListener

public final QCloudTask<T> removeResultListener(QCloudResultListener<T> resultListener)

removeAllListeners

public final void removeAllListeners()

getAllResultListeners

public final java.util.List<QCloudResultListener<T>> getAllResultListeners()

getAllProgressListeners

public final java.util.List<QCloudProgressListener> getAllProgressListeners()

getAllStateListeners

public final java.util.List<QCloudTaskStateListener> getAllStateListeners()

addProgressListener

public final QCloudTask<T> addProgressListener(QCloudProgressListener progressListener)

addProgressListeners

public final QCloudTask<T> addProgressListeners(java.util.List<QCloudProgressListener> progressListeners)

removeProgressListener

public final QCloudTask<T> removeProgressListener(QCloudProgressListener progressListener)

addStateListener

public final QCloudTask<T> addStateListener(QCloudTaskStateListener stateListener)

addStateListeners

public final QCloudTask<T> addStateListeners(java.util.List<QCloudTaskStateListener> stateListeners)

removeStateListener

public final QCloudTask<T> removeStateListener(QCloudTaskStateListener stateListener)

getResult

public T getResult()

getException

public java.lang.Exception getException()

onSuccess

protected void onSuccess()

onFailure

protected void onFailure()

onProgress

protected void onProgress(long complete,
                          long target)

onStateChanged

protected void onStateChanged(int newState)

getIdentifier

public final java.lang.String getIdentifier()

getTag

public final java.lang.Object getTag()

getWeight

public int getWeight()

setOnRequestWeightListener

public void setOnRequestWeightListener(QCloudTask.OnRequestWeightListener onRequestWeightListener)