如何在 C# 中将带有参数的函数绑定到包中

How to bind a function with arguments into a package in C#

本文关键字：参数 函数 绑定 包中      更新时间：2023-10-16

我正在使用C#编写线程池。

此线程池需要支持执行不同类型的函数。

以下是我需要的：

  1. 将函数及其参数绑定到函子(或可调用对象(中，其签名应为 void(void(
  2. 获取表示可调用包返回值的System.Threading.Tasks< TResult >

在CPP中，我可以使用一些模板魔术来做到这一点：

template <typename funtype, typename ...argstype>
std::future<typename std::result_of<funtype(argstype...)>::type> async(funtype&& func, argstype&&... args) {
//start function body↓
typedef std::packaged_task<std::result_of<funtype(argstype...)>::type(argstype...)> task_type;
auto task = std::make_shared<task_type>(std::forward<funtype>(func));
// bind to a callable object(functor) with signature void(void)
auto whatINeed= std::bind([task](argstype... args) mutable {
(*task)(std::forward<argstype>(args)...);
}, std::forward<argstype>(args)...);
//and we return the std::future which represents the return value of our package
//in C#, i need to return an Task<TResult>
return task->get_future();
}

在 C# 中，现在我写道：

public Task<TResult> async<TResult>(Delegate func, params object[] args)
{
var stdPromiseXD = new TaskCompletionSource<TResult>();
// the lambda is a callable object with signature void(void)
works.Enqueue(() =>
{
try
{
stdPromiseXD.SetResult((TResult)func.DynamicInvoke(args));
}
catch (Exception ex)
{
stdPromiseXD.SetException(ex);
}
});
// return the Task which equals std::future in CPP
return stdPromiseXD.Task;
}

但是这个 C# 版本不如 CPP 版本好。首先，它不支持不返回功能，其次，在某些情况下，DynamicInvoke方法可能会非常慢。

那么谁能告诉我如何将函数和参数绑定到更优雅的 C# 包中？

我建议使用Func<TResult>和Action而不是委托，然后在调用代码中使用闭包来简化用法。 Func 是返回结果的泛型强类型委托，Action 是不返回结果的泛型强类型委托。

public Task<TResult> Enqueue<TResult>(Func<TResult> func)
{
var stdPromiseXD = new TaskCompletionSource<TResult>();
// the lambda is a callable object with signature void(void)
works.Enqueue(() =>
{
try
{
stdPromiseXD.SetResult((TResult)func());
}
catch (Exception ex)
{
stdPromiseXD.SetException(ex);
}
});
// return the Task which equals std::future in CPP
return stdPromiseXD.Task;
}
public Task Enqueue(Action action)
{
return Enqueue<object>(() =>
{
action();
return null;
});
}

我用：

var arg1 = "x1";
var arg2 = "2nd";
var arg3 = "third";
var resultTask1 = tp.Enqueue(() => DoConsoleWrite(arg1, arg2, arg3));
var resultTask2 = tp.Enqueue(() => SumAllNumbers(1, 2, 3, 4, 5));
var resultTask3 = tp.Enqueue(() => ThrowException());
while (tp.Pop()) { }
resultTask1.GetAwaiter().GetResult();
var result2 = resultTask2.GetAwaiter().GetResult();
var result3Exception = resultTask3.Exception;

使用闭包的替代方法是为 func 的每个参数计数创建重载(Func<TResult>, Func<T1,TResult>, Func<T1,T2,Result>, etc和Action, Action<T1>, Action<T1,T2>, etc(

相关文章：