我有一些C#代码正在使用反射运行一些方法。该代码如下所示:
MyClass myClass = InitializeMyClass();
string[] methods = GetMethodsToRun();
foreach (var method in methods)
{
MethodInfo m = myClass.GetType().GetMethod(method);
m.Invoke(myClass, null);
}
此代码有效。但是,我需要并行运行这些方法。出于这个原因,我一直在研究任务并行库。为了通过任务并行库并行运行方法,我需要为每个方法创建Task
实例。为了尝试这样做,我将上面的代码更新为:
MyClass myClass = InitializeMyClass();
string[] methods = GetMethodsToRun();
foreach (var method in methods)
{
MethodInfo m = myClass.GetType().GetMethod(method);
Task<object> task = Task.Run<object>(method.Invoke(myClass, null));
}
但是,这不起作用,因为方法。Inkove 返回一个object
。我想通过使用.Run<object>
来传达我要运行的代码的返回类型。尽管如此,我仍然收到一个编译时错误,上面写着:
参数 1:无法从"对象"转换为"System.Func">
突然之间,我觉得我把这件事弄得太难了。我的问题是,如何通过 C# 将反射的方法作为任务调用?
谢谢
MyClass myClass = InitializeMyClass();
string[] methods = GetMethodsToRun();
foreach (var method in methods)
{
MethodInfo m = myClass.GetType().GetMethod(method);
Task.Run(() => m.Invoke(myClass, null));
}
以下是您正在使用的方法的签名:
public static Task<TResult> Run<TResult>(Func<TResult> function);
如果您注意到,泛型类型是结果的类型,而调用的参数是返回结果的函数。
因此,根据您的代码,您需要一个返回类型 object
的函数:
Task<object> task = Task.Run<object>(
() =>
{
return m.Invoke(myClass, null); //returns object
});
然后,您可以将结果与延续一起使用:
task.ContinueWith(
(o) =>
{
Console.WriteLine(o.Result); //Result contains the actual result of the method call.
});
在这两种情况下,我们都使用 lambda 表达式定义了匿名函数。不一定非要这样。您也可以提供自己的函数:
task.ContinueWith(WriteObject);
private void WriteObject(Task<object> o)
{
Console.WriteLine(o.Result);
}
Task.Run()
需要System.Func<TResult>
(或System.Action
(的欺骗。
您的代码会立即调用该函数,然后将其结果(不是委托(传递给Task.Run()
。 那行不通。
相反,您需要调用 Delegate.CreateDelegate()
来创建指向MethodInfo
(与您的实例(的正确类型的委托(这将取决于方法的返回类型(,将其转换为 Func<T>
或 Action
,然后将其传递给 Task.Run()
。