程序包 com.agentsflex.core.util

类 Retryer

java.lang.Object

com.agentsflex.core.util.Retryer

public final class Retryer
extends Object

重试执行器。

设计原则： - Builder 仅用于构造配置 - Retryer 实例是线程安全的（无状态），可全局复用

嵌套类概要

嵌套类

修饰符和类型	类	说明
static class	Retryer.Builder

字段概要

字段

修饰符和类型	字段	说明
private static final Predicate<Exception>	DEFAULT_RETRYABLE_EXCEPTION
private final boolean	exponentialBackoff
private final long	initialDelayMs
private final long	maxDelayMs
private final int	maxRetries
private final String	operationName
private final Predicate<Exception>	retryOnException
private final Predicate<Object>	retryOnResult
private final long	totalTimeoutMs

构造器概要

构造器

限定符	构造器	说明
private	Retryer(Retryer.Builder builder)

方法概要

修饰符和类型	方法	说明
static Retryer.Builder	builder()
void	execute(Runnable task)
<T> T	execute(Callable<T> task)
static void	retry(Runnable task, int maxRetries, long initialDelayMs)
static <T> T	retry(Callable<T> task, int maxRetries, long initialDelayMs)
private void	sleepSafely(long sleepMs)

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

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

字段详细资料

maxRetries

private final int maxRetries

initialDelayMs

private final long initialDelayMs

maxDelayMs

private final long maxDelayMs

exponentialBackoff

private final boolean exponentialBackoff

totalTimeoutMs

private final long totalTimeoutMs

retryOnException

private final Predicate<Exception> retryOnException

retryOnResult

private final Predicate<Object> retryOnResult

operationName

private final String operationName

DEFAULT_RETRYABLE_EXCEPTION

private static final Predicate<Exception> DEFAULT_RETRYABLE_EXCEPTION

构造器详细资料

Retryer

private Retryer(Retryer.Builder builder)

方法详细资料

builder

public static Retryer.Builder builder()

retry

public static <T> T retry(Callable<T> task,
 int maxRetries,
 long initialDelayMs)

retry

public static void retry(Runnable task,
 int maxRetries,
 long initialDelayMs)

execute

public <T> T execute(Callable<T> task)

execute

public void execute(Runnable task)

sleepSafely

private void sleepSafely(long sleepMs)