Как использовать Async.Parallel в асинхронном рабочем процессе?

Question

Я пытался научиться использовать асинхронные методы на основе сообщений. Ниже приведен упрощенный вариант того, что я пытался сделать. Я пытаюсь использовать конечный автомат в пределах MailboxProcessor внутри объекта. В целом кажется, что логика может быть гораздо более простой по сравнению с использованием методов, основанных на событиях. У меня проблема, но когда я пытаюсь использовать Async.Parallel. В коде, следующем за оператором printfn "Eval %i" v, производится оценка дважды для i1 & i2 вместо одного раза для каждого. Это заставляет меня думать, что я неправильно использую Async.Parallel. Существует ли альтернативный метод, который должен использоваться в асинхронном рабочем процессе?

type Input(v) = 

    let agent = 
     MailboxProcessor.Start(fun inbox -> 
      let rec loop() = 
       async { 
        let! (msg : AsyncReplyChannel<int>) = inbox.Receive() 
        printfn "Eval %i" v 
        msg.Reply(v) 
        return! loop() 
       } 
      loop()) 

    member this.Eval = agent.PostAndAsyncReply(fun r -> r) 

let i1 = Input(1) 
let i2 = Input(2) 

async { 
    let! nodeValues = [ i1; i2 ] 
         |> Seq.map(fun n -> n.Eval) 
         |> Async.Parallel 
    return nodeValues 
} 
|> Async.RunSynchronously 

Answer 1

Это ошибка в F # 3.0. Async.Parallel звонки Seq.toArray два раза. Запустите свой код под F # 3.1, и он будет печатать только один раз. Here's the fix in the F# source repository.