org.noear.solon.scheduling.retry

类 RetryableTask<T>

java.lang.Object

org.noear.solon.scheduling.retry.RetryableTask<T>

public class RetryableTask<T>
extends Object

重试任务类

从以下版本开始:

2.3

作者:

kongweiguang

方法概要

限定符和类型	方法和说明
RetryableTask<T>	execute() 开始执行重试方法
T	get() 获取答案
RetryableTask<T>	interval(long interval) 设置间隔时间
RetryableTask<T>	maxRetryCount(long maxRetryCount) 最大重试次数
static RetryableTask<Void>	of(org.noear.solon.core.util.RunnableEx run) 创建一个没有返回值的重试任务
static <T> RetryableTask<T>	of(org.noear.solon.core.util.SupplierEx<T> sup) 创建一个有返回值的重试任务
RetryableTask<T>	recover(Recover<T> recover) 达到最大重试次数后执行的备用方法，入参是重试过程中的异常
RetryableTask<T>	retryForExcludes(Class<? extends Throwable>... exs)
RetryableTask<T>	retryForIncludes(Class<? extends Throwable>... exs) 指定的异常类型需要重试
RetryableTask<T>	unit(TimeUnit unit) 设置间隔时间单位

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

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

方法详细资料

of

public static RetryableTask<Void> of(org.noear.solon.core.util.RunnableEx run)

创建一个没有返回值的重试任务

参数:

run - 任务

返回:

Void

of

public static <T> RetryableTask<T> of(org.noear.solon.core.util.SupplierEx<T> sup)

创建一个有返回值的重试任务

参数:

sup - 任务

返回:

执行结果

maxRetryCount

public RetryableTask<T> maxRetryCount(long maxRetryCount)

最大重试次数

参数:

maxRetryCount - 次数

返回:

this

interval

public RetryableTask<T> interval(long interval)

设置间隔时间

参数:

interval - 间隔时间

unit

public RetryableTask<T> unit(TimeUnit unit)

设置间隔时间单位

参数:

unit - 时间单位

retryForIncludes

public final RetryableTask<T> retryForIncludes(Class<? extends Throwable>... exs)

指定的异常类型需要重试

参数:

exs - 异常集合

返回:

this

retryForExcludes

public final RetryableTask<T> retryForExcludes(Class<? extends Throwable>... exs)

recover

public RetryableTask<T> recover(Recover<T> recover)

达到最大重试次数后执行的备用方法，入参是重试过程中的异常

参数:

recover - 兜底策略

返回:

this

get

public T get()

获取答案

返回:

执行方法返回的值

execute

public RetryableTask<T> execute()
                         throws Throwable

开始执行重试方法

返回:

this

抛出:

Throwable