如何在F#中调用C#非异步函数并返回已启动的Async<T>

嘿，这个需求很常见，我来给你两个靠谱的实现方案，完全符合你的要求——不用System.Threading.Task<Bar>，返回已启动的Async<Bar>，还不会阻塞主线程！

方案1：用F# Async标准组合子（简洁版） #

这个方案用F#内置的Async.StartChild来快速封装同步调用，代码非常简洁：

open System

// 假设你已经引用了包含Foo类的C#库，Bar类型也能正常访问
let bazAsync () : Async<Bar> =
    // 先把同步调用封装成惰性的Async工作流
    let cpuBoundWork = async {
        return Foo.Baz() // 这里调用CPU密集型的同步方法
    }
    // 启动这个工作流到后台线程，返回已启动的Async<Bar>
    Async.StartChild cpuBoundWork |> Async.RunSynchronously

解释： #

• cpuBoundWork是一个惰性的Async<Bar>，定义后不会立即执行，只是描述了要做的工作。
• Async.StartChild会立刻把这个工作流放到.NET线程池的工作线程上执行，然后返回一个Async<Async<Bar>>。我们用Async.RunSynchronously解开它，这一步几乎不会阻塞——它只是完成启动任务的操作，不是等待结果。
• 最终返回的Async<Bar>已经在后台运行了，你可以后续用Async.RunSynchronously（如果必须阻塞等结果）或者Async.StartWithContinuations（非阻塞处理结果/错误）来获取它的输出。

方案2：手动用线程池+延续（底层可控版） #

如果你想更底层地控制线程调度，可以用Async.FromContinuations结合线程池来实现，同样不依赖Task：

open System.Threading

let bazAsync () : Async<Bar> =
    Async.FromContinuations(fun (onSuccess, onError, onCancel) ->
        // 把CPU密集型任务放到线程池执行
        ThreadPool.QueueUserWorkItem(fun _ ->
            try
                // 执行同步调用
                let result = Foo.Baz()
                // 成功时调用延续传递结果
                onSuccess result
            with
            // 捕获异常并传递错误延续
            | ex -> onError ex
        ) |> ignore
    )

解释： #

• Async.FromContinuations让我们手动构建Async工作流，通过三个回调函数处理成功、错误和取消的场景。
• ThreadPool.QueueUserWorkItem直接把任务放到线程池后台执行，避免阻塞主线程。
• 任务执行完成后，我们通过onSuccess传递结果；如果抛出异常，就用onError传递错误信息。
• 这个版本返回的Async<Bar>同样是启动后立即执行的，完全不依赖Task类型。

两种方案都能满足你的需求，选哪个取决于你想要简洁性还是更底层的控制权~

内容的提问来源于stack exchange，提问作者knocte