将任何给定函数转换为等待任务

Question

以下代码的目标是将任何给定函数转换为可等待函数。这个想法是在从数据库中获取数据时使用它，让代码可以灵活地使用同步获取函数（我当前的 ORM 的强制执行），或者使用与异步相同的函数。

我知道代码背后的概念可能有很多问题。到目前为止，我只是想摆脱编译器错误，这样我就可以运行代码并检查行为。但是，我当然愿意事先讨论这个概念，如果它背后的整个想法是错误的，那么可以更有效地利用我的时间寻找另一个解决方案。

async static void Main()
{
    // The following line gives a compiler error:
    // Error    1   The best overloaded method match for 'CastFuncToTask<int>(System.Func<int>)' has some invalid arguments 
    int task = await CastFuncToTask<int>(TestFunc(2));
}

private static Task<T> CastFuncToTask<T>(Func<T> func)
{
    TaskCompletionSource<T> taskCompletionSource = new TaskCompletionSource<T>();
    T result = func.Invoke();
    taskCompletionSource.SetResult(result);
    return taskCompletionSource.Task;
}

private static int TestFunc(int testInt) 
{
    return testInt * 2;
}

Answer 1

运行 .NET 4.5，您可以通过以下方式大大简化您的代码：

int task = await Task.FromResult(TestFunc(2));

无需自己将其包装在 TaskCompletionSource 中。

我知道这个概念可能有很多问题 代码后面。

如果您尝试异步查询数据库，那么此解决方案肯定无济于事。它只是人为地将您的结果包装在Task 中。如果你真的想异步查询你的数据库，你需要使用你的数据库提供者提供的异步方法。

如果您正在使用 MySQL 并寻找支持异步的驱动程序，请查看 Dapper

Answer 2

你可以使用：

await Task.Run(() => obj.functionname());

Answer 3

改成

int task = await CastFuncToTask<int>(()=>TestFunc(2));

在您的代码中，为CastFuncToTask 提供的输入是int（TestFunc 返回的内容。）但它需要一个委托Func<T>。

Answer 4

我的方法是这样的：

public Task<int> SetOffAsync()
{
    return Task<int>.Factory.StartNew(() =>
    { 
        /*do something else*/
        return 42;
    });
}

你可以这样称呼：

int var = await SetOffAsync();

Answer 5

使用 Windows 窗体应用程序，我确认第一个调用阻止了第二个调用。所以最好的解决方案是使用 Task.Run() 和 lambda 表达式。

    private async void button1_Click(object sender, EventArgs e)
    {
        button1.Text = "...";
        var result = await Task.FromResult(TestFunc(2));
        button1.Text = result.ToString();
    }

    private async void button2_Click(object sender, EventArgs e)
    {
        button2.Text = "...";
        var result = await Task.Run(() => TestFunc(2));
        button2.Text = result.ToString();
    }

    private int TestFunc(int x)
    {
        System.Threading.Thread.Sleep(5000);
        return x;
    }

编译器无法知道您不想评估 TestFunc(2) 而是将其用作委托，并且只会首先执行该方法，并且 Task.FromResult 只会将 return value 包装在一个任务中。这不是你想要的。

Answer 6

以下代码可能对其他人有所帮助：

注意：GenericMethod 是我们作为 Func 传递的参数名称，输入 (T1) 和输出 (T2) 为泛型类型。 任务工厂将提供运行任务所需的访问权限。

    public async Task<T2> GenericAsyncCall<T1, T2>(Func<T1, T2> GenericMethod, T1 input)
    {
        var _output = await Task.Factory.StartNew(() => {
            var output = GenericMethod.Invoke(input);
            return output;
        });

        return (T2)_output;
    }

Answer 7

问题在于 CastFuncToTask 同步运行。 如果 Func 是无参数的，你可以这样做：

public static Task<T> ToTask(this Func<T> func) => Task.Factory.StartNew(() => func());

无论如何，我们都可以使用 TaskCompletionSource 并返回我们想要的东西，而不管方法如何。假设我们有 Action 而不是 Func

public static Task<string> ToTask(this Action action)    
{    TaskCompletionSource<string> taskCompletionSource = new 
           TaskCompletionSource<string>();
           string result = null;
           try
           {
               Task.Factory.StartNew(() => action());
           }
           catch (Exception ex)
           {
               result = ex.Message;
           }
           taskCompletionSource.SetResult(result);
           return taskCompletionSource.Task;
       }