【转载】C#异常Retry通用类
2023-09-14 09:06:38 时间
//Retry机制 public static class Retry { /// <summary> /// 重试零个参数无返回值的方法 /// </summary> /// <param name="action">执行方法方法</param> /// <param name="retryInterval">重试间隔</param> /// <param name="retryCount">重试次数</param> public static void Execute(Action action, TimeSpan retryInterval, int retryCount = 3) { Execute<object>(() => { action(); return null; }, retryInterval, retryCount); } /// <summary> /// 重试一个参数无返回值的方法 /// </summary> /// <typeparam name="T1">参数类型1</typeparam> /// <param name="action">执行方法方法</param> /// <param name="arg1">参数1</param> /// <param name="retryInterval">重试间隔</param> /// <param name="retryCount">重试次数</param> public static void Execute<T1>(Action<T1> action, T1 arg1, TimeSpan retryInterval, int retryCount = 3) { Execute<T1, object>((x1) => { action(arg1); return null; }, arg1, retryInterval, retryCount); } /// <summary> /// 重试两个参数无返回值的方法 /// </summary> /// <typeparam name="T1">参数类型1</typeparam> /// <typeparam name="T2">参数类型2</typeparam> /// <param name="action">执行方法方法</param> /// <param name="arg1">参数1</param> /// <param name="arg2">参数2</param> /// <param name="retryInterval">重试间隔</param> /// <param name="retryCount">重试次数</param> public static void Execute<T1, T2>(Action<T1, T2> action, T1 arg1, T2 arg2, TimeSpan retryInterval, int retryCount = 3) { Execute<T1, T2, object>((x1, x2) => { action(arg1, arg2); return null; }, arg1, arg2, retryInterval, retryCount); } /// <summary> /// 重试三个参数无返回值的方法 /// </summary> /// <typeparam name="T1">参数类型1</typeparam> /// <typeparam name="T2">参数类型2</typeparam> /// <typeparam name="T3">参数类型3</typeparam> /// <param name="action">执行方法方法</param> /// <param name="arg1">参数1</param> /// <param name="arg2">参数2</param> /// <param name="arg3">参数3</param> /// <param name="retryInterval">重试间隔</param> /// <param name="retryCount">重试次数</param> public static void Execute<T1, T2, T3>(Action<T1, T2, T3> action, T1 arg1, T2 arg2, T3 arg3, TimeSpan retryInterval, int retryCount = 3) { Execute<T1, T2, T3, object>((x1, x2, x3) => { action(arg1, arg2, arg3); return null; }, arg1, arg2, arg3, retryInterval, retryCount); } /// <summary> /// 重试四个参数无返回值的方法 /// </summary> /// <typeparam name="T1">参数类型1</typeparam> /// <typeparam name="T2">参数类型2</typeparam> /// <typeparam name="T3">参数类型3</typeparam> /// <typeparam name="T4">参数类型4</typeparam> /// <param name="action">执行方法方法</param> /// <param name="arg1">参数1</param> /// <param name="arg2">参数2</param> /// <param name="arg3">参数3</param> /// <param name="arg4">参数4</param> /// <param name="retryInterval">重试间隔</param> /// <param name="retryCount">重试次数</param> public static void Execute<T1, T2, T3, T4>(Action<T1, T2, T3, T4> action, T1 arg1, T2 arg2, T3 arg3, T4 arg4, TimeSpan retryInterval, int retryCount = 3) { Execute<T1, T2, T3, T4, object>((x1, x2, x3, x4) => { action(arg1, arg2, arg3, arg4); return null; }, arg1, arg2, arg3, arg4, retryInterval, retryCount); } /// <summary> /// 重试零个参数带返回值 /// </summary> /// <typeparam name="T">返回类型</typeparam> /// <param name="func">执行的方法</param> /// <param name="retryInterval">重试间隔</param> /// <param name="retryCount">重试次数</param> /// <returns>返回类型T</returns> public static T Execute<T>(Func<T> func, TimeSpan retryInterval, int retryCount = 3) { var exceptions = new List<Exception>(); for (int retry = 0; retry < retryCount; retry++) { try { return func(); } catch (Exception ex) { exceptions.Add(ex); Thread.Sleep(retryInterval); } } throw new AggregateException(exceptions); } /// <summary> /// 重试一个参数带返回值 /// </summary> /// <typeparam name="T1">参数类型1</typeparam> /// <typeparam name="T">返回类型</typeparam> /// <param name="func">执行的方法</param> /// <param name="arg1">参数1</param> /// <param name="retryInterval">重试间隔</param> /// <param name="retryCount">重试次数</param> /// <returns>返回类型T</returns> public static T Execute<T1, T>(Func<T1, T> func, T1 arg1, TimeSpan retryInterval, int retryCount = 3) { var exceptions = new List<Exception>(); for (int retry = 0; retry < retryCount; retry++) { try { return func(arg1); } catch (Exception ex) { exceptions.Add(ex); Thread.Sleep(retryInterval); } } throw new AggregateException(exceptions); } /// <summary> /// 重试两个参数带返回值 /// </summary> /// <typeparam name="T1">参数类型1</typeparam> /// <typeparam name="T2">参数类型2</typeparam> /// <typeparam name="T">返回类型</typeparam> /// <param name="func">执行的方法</param> /// <param name="arg1">参数1</param> /// <param name="arg2">参数2</param> /// <param name="retryInterval">重试间隔</param> /// <param name="retryCount">重试次数</param> /// <returns>返回类型T</returns> public static T Execute<T1, T2, T>(Func<T1, T2, T> func, T1 arg1, T2 arg2, TimeSpan retryInterval, int retryCount = 3) { var exceptions = new List<Exception>(); for (int retry = 0; retry < retryCount; retry++) { try { return func(arg1, arg2); } catch (Exception ex) { exceptions.Add(ex); Thread.Sleep(retryInterval); } } throw new AggregateException(exceptions); } /// <summary> /// 重试三个参数带返回值 /// </summary> /// <typeparam name="T1">参数类型1</typeparam> /// <typeparam name="T2">参数类型2</typeparam> /// <typeparam name="T3">参数类型3</typeparam> /// <typeparam name="T">返回类型</typeparam> /// <param name="func">执行的方法</param> /// <param name="arg1">参数1</param> /// <param name="arg2">参数2</param> /// <param name="arg3">参数3</param> /// <param name="retryInterval">重试间隔</param> /// <param name="retryCount">重试次数</param> /// <returns>返回类型T</returns> public static T Execute<T1, T2, T3, T>(Func<T1, T2, T3, T> func, T1 arg1, T2 arg2, T3 arg3, TimeSpan retryInterval, int retryCount = 3) { var exceptions = new List<Exception>(); for (int retry = 0; retry < retryCount; retry++) { try { return func(arg1, arg2, arg3); } catch (Exception ex) { exceptions.Add(ex); Thread.Sleep(retryInterval); } } throw new AggregateException(exceptions); } /// <summary> /// 重试四个参数带返回值 /// </summary> /// <typeparam name="T1">参数类型1</typeparam> /// <typeparam name="T2">参数类型2</typeparam> /// <typeparam name="T3">参数类型3</typeparam> /// <typeparam name="T4">参数类型4</typeparam> /// <typeparam name="T">返回类型</typeparam> /// <param name="func">执行的方法</param> /// <param name="arg1">参数1</param> /// <param name="arg2">参数2</param> /// <param name="arg3">参数3</param> /// <param name="arg4">参数4</param> /// <param name="retryInterval">重试间隔</param> /// <param name="retryCount">重试次数</param> /// <returns>返回类型T</returns> public static T Execute<T1, T2, T3, T4, T>(Func<T1, T2, T3, T4, T> func, T1 arg1, T2 arg2, T3 arg3, T4 arg4, TimeSpan retryInterval, int retryCount = 3) { var exceptions = new List<Exception>(); for (int retry = 0; retry < retryCount; retry++) { try { return func(arg1, arg2, arg3, arg4); } catch (Exception ex) { exceptions.Add(ex); Thread.Sleep(retryInterval); } } throw new AggregateException(exceptions); } }
相关文章
- C# 系统应用之获取Windows最近使用记录
- WinForm实现简单的拖拽功能(C#)(2)
- C# WinForm捕获全局异常
- Win10系列:C#应用控件基础6
- [C#]用HttpWebRequest加载证书建立SSL通道时发生异常的解决办法
- C#读取CSV
- java和C#异常处理的差异
- 重学c#系列——异常(六)
- c# checked 和 unchecked
- 使用thrift进行跨语言调用(php c# java)
- C# 异常处理(Catch Throw)IL分析
- C#,int转成string,string转成int
- C# 参数数组
- Atitit.常见的异常分类 目录 1. 双元分类法1 1.1. 按照语言分 java js c# php等1 1.2. 通用常见异常vs 特定异常1 1.3. Runtime ex vs c
- Atitit 跨平台异常处理(2)--------异常转换 -----java c# js异常对象结构比较and转换
- Atitit 跨平台异常处理(2)--------异常转换 -----java c# js异常对象结构比较and转换
- Atitit.跨语言反射api 兼容性提升与增强 java c#。Net php js
- Atitit.跨语言 java c#.net php js常用的codec encode算法api 兼容性 应该内置到语言里面
- (二十七)c#Winform自定义控件-多输入窗体-HZHControls
- C# winform坐标系类型详解
- C#winform各种异常处理方式
- (63)C#里.net Framework的版本
- CSharp(C#)语言_异常和异常处理
- 你也可以写个聊天程序 - C# Socket学习1
- C#/.NET CTS和CLS:公共类型系统和公共语言规范
- C#线程同步的几种方法