我希望能够从 F# 使用 C# 库。大多数情况下，这非常简单。但是，如果我尝试调用返回 Task<T> 的函数我无法获得返回值。

所以，我有具有以下定义的 C# 方法:

public async Task<TEvent> ReadEventAsync<TEvent>(string streamName, int position) where TEvent: class

我正在尝试使用 F# 中的这个方法，如下所示:

let readEventFromEventStore<'a when 'a : not struct> (eventStore:IEventStoreRepository) (streamName:string) (position:int) = 
     async {
            return eventStore.ReadEventAsync(streamName, position) 
            |> Async.AwaitTask
            }

我将此函数部分应用到一个 IEventStoreRepository 的实例中以及我希望从中检索事件的流名称:

let readEvent = readEventFromEventStore eventStore streamName

然后，最后，我应用剩余的参数:

let event = readEvent StreamPosition.Start

当我得到 event 的值时这是一个FSharpAsync<object>而不是 T来自 Task<T>这是我预料到的。

在 F# 中调用 async 的正确方法是什么？用 C# 编写的方法，返回类型为 Task<T>并访问 T 的值？

最佳答案

首先，在您的用例中，不需要 async { }堵塞。 Async.AwaitTask returns an Async<'T> , 所以你的 async { } block 只是展开 Async得到并立即重新包装它的对象。

现在我们已经摆脱了不必要的 async block ，让我们看看你得到的类型，以及你想要得到的类型。你有一个 Async<'a> , 你想要一个 'a 类型的对象.翻看available Async functions , 类型签名如 Async<'a> -> 'a 的那个是 Async.RunSynchronously .它有两个可选参数，一个int。和一个 CancellationToken ，但如果您将它们排除在外，您将获得所需的函数签名。果然，一旦你查看文档就会发现 Async.RunSynchronously F# 等价于 C# 的 await ，这就是您想要的。 有点(但不完全)像 C# 的 await . C# 的 await是一个可以在 async 中使用的语句函数，而 F# 的 Async.RunSynchronously需要 async对象阻塞当前线程直到async对象已完成运行。在这种情况下，这正是您要寻找的。

let readEventFromEventStore<'a when 'a : not struct> (eventStore:IEventStoreRepository) (streamName:string) (position:int) =
    eventStore.ReadEventAsync(streamName, position) 
    |> Async.AwaitTask
    |> Async.RunSynchronously

这应该能找到您要找的东西。并注意找出所需函数的函数签名，然后查找具有该签名的函数的技术。这对将来会有很大帮助。

更新:感谢 Tarmil 在评论中指出我的错误:Async.RunSynchronously 不等同于 C# 的 await .它非常相似，但自 RunSynchronously 以来有一些重要的微妙之处需要注意。阻塞当前线程。 (您不想在 GUI 线程中调用它。)

更新 2:如果您想在不阻塞当前线程的情况下等待异步结果，通常是这样的模式的一部分:

1. 调用一些异步操作
2. 等待结果
3. 用那个结果做点什么

编写该模式的最佳方式如下:

let equivalentOfAwait () =
    async {
        let! result = someAsyncOperation()
        doSomethingWith result
    }

以上假设doSomethingWith返回 unit ，因为您称它为副作用。相反，如果它返回一个值，你会这样做:

let equivalentOfAwait () =
    async {
        let! result = someAsyncOperation()
        let value = someCalculationWith result
        return value
    }

或者，当然:

let equivalentOfAwait () =
    async {
        let! result = someAsyncOperation()
        return (someCalculationWith result)
    }

假设 someCalculationWith不是异步操作。相反，如果您需要将两个异步操作链接在一起，其中第二个使用第一个的结果——或者甚至是某种序列中的三个或四个异步操作——那么它看起来像这样:

let equivalentOfAwait () =
    async {
        let! result1 = someAsyncOperation()
        let! result2 = nextOperationWith result1
        let! result3 = penultimateOperationWith result2
        let! finalResult = finalOperationWith result3
        return finalResult
    }

除了let!其次是 return完全等同于 return! ，所以最好写成:

let equivalentOfAwait () =
    async {
        let! result1 = someAsyncOperation()
        let! result2 = nextOperationWith result1
        let! result3 = penultimateOperationWith result2
        return! (finalOperationWith result3)
    }

所有这些函数都会产生一个 Async<'T> , 其中'T将是 async 中最终函数的返回类型堵塞。要真正运行那些异步 block ，你要么做 Async.RunSynchronously如前所述，或者您可以使用各种 Async.Start 之一函数( Start 、 StartImmediate 、 StartAsTask 、 StartWithContinuations 等)。 Async.StartImmediate example稍微谈一下 Async.SwitchToContext function同样，这可能是您想要阅读的内容。但是我对SynchronizationContext还不够熟悉告诉你的远不止这些。

关于c# - 在 F# 中正确等待返回类型为 Task<T> 的异步 C# 方法，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/41743602/