c# 在回调中调用 endinvoke，使用泛型

Question

在 BeginInvoke 之后的回调中，AsyncResult.AsyncDelegate 需要转换为正确的类型，然后才能访问 EndInvoke。

但是我正在使用泛型，那么我是否需要为 N 个泛化方法定义 N 个回调？

这是类:

public class Async
    {
        public delegate object Func(); //void with no parameter
        public delegate TResult Func<T, TResult>(T arg); //one parameter with result

        public static void Execute(IAsyncSubscriber subscriber, Func action)
        {
            action.BeginInvoke(Callback, subscriber);
        }

        public static void Execute<T, T1>(IAsyncSubscriber subscriber, T param, Func<T, T1> action)
        {
            action.BeginInvoke(param, Callback, subscriber);
        }

        private static void Callback(IAsyncResult ar)
        {
            AsyncResult result = (AsyncResult)ar;
            IAsyncSubscriber subscriber = (IAsyncSubscriber)result.AsyncState;
            Func action = (Func) result.AsyncDelegate;
            object returnValue = action.EndInvoke(result); //To call endinvoke 
            subscriber.Callback(returnValue);
        }
    }

Answer 1

有几种方法可以避免定义 N 个回调:

1. 您可以在 BeginInvoke 调用中将相应的 EndInvoke 方法作为状态传递。例如

   private delegate T EndInvokeDelegate<T>(IAsyncResult ar);
   
   public static void Execute<T, T1>(IAsyncSubscriber subscriber, T param, Func<T, T1> action)
   {
       action.BeginInvoke(param, Callback<T1>, new object[]{subscriber, new new EndInvokeDelegate<T1>(action.EndInvoke)});
   }
   
   public static void Execute<T, T1, T2>(IAsyncSubscriber subscriber, T param1, T1 param2, Func<T, T1, T2> action)
   {
       action.BeginInvoke(param1, param2, Callback<T2>, new object[]{subscriber, new new EndInvokeDelegate<T2>(action.EndInvoke)});
   }
   
   private static void Callback<TR>(IAsyncResult ar)
   {
       object[] stateArr = (object[])ar.AsyncState;
       IAsyncSubscriber subscriber = (IAsyncSubscriber)stateArr[0];
       EndInvokeDelegate<TR> action = (EndInvokeDelegate<TR>)stateArray[1];
       TR returnValue = action(ar);
       subscriber.Callback(returnValue);
   }     
   

   您还可以通过将 stateArray[1] 视为 MultiCastDelegate 并在其上使用 DynamicInvoke 来使 Callback 成为非泛型，但这会很慢。

2. 对于 .Net 2.0 和 3.0，您可以使用反射，例如

   Type actionType= result.AsyncDelegate.GetType();
   var minfo = actionType.GetMethod("EndInvoke");
   object returnValue = minfo.Invoke(res.AsyncDelegate, new object[] { ar });
   

3. 对于 .Net 4.0，您可以使用动态。例如

   dynamic action = result.AsyncDelegate; 
   object returnValue = action.EndInvoke(result);