Как ждать асинхронных закончить

Question

Я хотел бы запустить некоторый асинхронные рабочий процесс, а затем ждать его, чтобы закончить перед печатью некоторых результатов, например:

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 программа выполняет несколько операций ввода-вывода, поэтому я хочу дождаться, пока самый медленный закончен, прежде чем продолжить.

Answer 1

Ну, отвечая на мой собственный вопрос, кажется хромым, но это, похоже, работает. Кто-то придумать что-то лучше, чтобы я мог присудить им ответ :)

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

let creatework() = 
    [1..5] |> Seq.map dowork |> Async.Parallel |> Async.RunSynchronously 

creatework()  
printfn "finished" 

Это дает различные выходные, но «закончил» до сих пор всегда в последний раз ...

Answer 2

я обнаружил, что это удобно использовать MailboxProcessor, чтобы убедиться, что все побочные эффекты (например, printfn) происходят в одном потоке. Используйте MailboxProcessor.PostAndReply (singleResult), чтобы возить результаты работы (будь то строки для печати) в один и тот же контекст синхронизации и предоставить другой тип сообщения, возвращающий агрегированные значения. Можно использовать объединение для типов этих сообщений.