相关疑难解决方法(0)

我想运行一些异步工作流,然后在打印一些结果之前等待它完成,例如:

let dowork n =
    async {
        do printfn "work %d" n
    }

let creatework() =
    async {
        for x in [1..5] do
            Async.Start(dowork x)
    }

Async.RunSynchronously(creatework())    
printfn "finished"

当我运行它时,我希望所有的dowork调用在打印"完成"之前完成.但是我得到这样的结果:

工作2工作3工作4工作5完成工作1

我尝试从creatework()中删除异步,但在运行异步工作流之前打印"已完成".

在真正的dowork中,程序会执行一些IO,所以我想在继续之前等待最慢的完成.

我在这里有点沮丧.我知道我已经掌握了所有的东西,但我无法弄清楚如何将它们结合起来......

let saveImageToDisk path content =
    async {
        use s = new FileStream(path, FileMode.OpenOrCreate)
        do! s.AsyncWrite(content)
        printfn "Done writing %A" path
        } // returns Async<unit>

let getImages imageUrls =
    imageUrls
        |> Seq.map (fun url -> topath url, getImage url)
        //Next line not happy because content is Async<byte[]> instead of byte[]
        |> Seq.map (fun (path, content) -> saveImageToDisk path content)
        |> Async.Parallel
        |> Async.RunSynchronously