public class RetryableTask<T>
extends java.lang.Object
限定符和类型 | 方法和说明 |
---|---|
RetryableTask<T> |
execute()
开始执行重试方法
|
T |
get()
获取答案
|
RetryableTask<T> |
interval(long interval)
设置间隔时间
|
RetryableTask<T> |
maxRetryCount(long maxRetryCount)
最大重试次数
|
static RetryableTask<java.lang.Void> |
of(Callee task)
创建重试任务
|
RetryableTask<T> |
recover(Recover<T> recover)
达到最大重试次数后执行的备用方法,入参是重试过程中的异常
|
RetryableTask<T> |
retryForExcludes(java.lang.Class<? extends java.lang.Throwable>... exs) |
RetryableTask<T> |
retryForIncludes(java.lang.Class<? extends java.lang.Throwable>... exs)
指定的异常类型需要重试
|
RetryableTask<T> |
unit(java.util.concurrent.TimeUnit unit)
设置间隔时间单位
|
public static RetryableTask<java.lang.Void> of(Callee task)
task
- 任务public RetryableTask<T> maxRetryCount(long maxRetryCount)
maxRetryCount
- 次数public RetryableTask<T> interval(long interval)
interval
- 间隔时间public RetryableTask<T> unit(java.util.concurrent.TimeUnit unit)
unit
- 时间单位public final RetryableTask<T> retryForIncludes(java.lang.Class<? extends java.lang.Throwable>... exs)
exs
- 异常集合public final RetryableTask<T> retryForExcludes(java.lang.Class<? extends java.lang.Throwable>... exs)
public RetryableTask<T> recover(Recover<T> recover)
recover
- 兜底策略public T get()
public RetryableTask<T> execute() throws java.lang.Throwable
java.lang.Throwable