RetryUtils
public class RetryUtils {
private static final int DEFAULT_RETRY = 3;
private static final ExecuteFailedWarn DEFAULT_WARN_FUNCTION = System.out::println;
private static final OutputFunction DEFAULT_OUTPUT = System.out::println;
public static void call(int retryTimes, RunFunction runFunction, ExecuteFailedWarn failed, OutputFunction outputFunction) {
int flag = 0;
while (flag < retryTimes) {
try {
outputFunction.output(runFunction.execute());
break;
}catch (Exception e) {
failed.failed("Retry for msg: " + e.getMessage());
flag++;
}
}
}
public static void call(RunFunction runFunction, OutputFunction outputFunction) {
RetryUtils.call(DEFAULT_RETRY, runFunction, DEFAULT_WARN_FUNCTION, outputFunction);
}
public static void call(RunFunction runFunction) {
RetryUtils.call(DEFAULT_RETRY, runFunction, DEFAULT_WARN_FUNCTION, DEFAULT_OUTPUT);
}
public static void call(int times, RunFunction runFunction) {
RetryUtils.call(times, runFunction, DEFAULT_WARN_FUNCTION, DEFAULT_OUTPUT);
}
}
OutputFunction
@FunctionalInterface
public interface OutputFunction {
void output(Object res);
}
RunFunction
@FunctionalInterface
public interface RunFunction {
Object execute() throws Exception;
}
ExecuteFailedWarn
@FunctionalInterface
public interface ExecuteFailedWarn {
void failed(String msg);
}
test
public static void main(String[] args) {
RetryUtils.call(3, () -> {
if (System.currentTimeMillis()%19 != 0) {
throw new Exception("adfasdfa");
}
return new Object();
});
}
