MailboxProcessor.PostAndReply opción de diseño

Question

cuanto a:

member this.PostAndReply : (AsyncReplyChannel<'Reply> -> 'Msg) * ?int -> 'Reply 

No puedo entender por qué la firma se ve tan contrario a la intuición para mí. Lo que queremos hacer es publicar un mensaje a un agente y esperar una respuesta. ¿Por qué tenemos que darle una función extraña como un 'mensaje'?

Véase de nuevo este fragmento de MSDN:

let rec loop() = 
    printf "> " 
    let input = Console.ReadLine() 
    printThreadId("Console loop") 
    let reply = agent.PostAndReply(fun replyChannel -> input, replyChannel) 
    if (reply <> "Stopping.") then 
     printfn "Reply: %s" reply 
     loop() 
    else 
     () 
loop() 

prefiero prefieren algo como esto:

member this.PostAndReply : 'Msg * ?int -> 'Reply 

Gracias

Answer 1

Este tipo de firma se ve muy confuso cuando lo ves para el primera vez, pero tiene sentido.

El diseño F # biblioteca
La idea detrás de la es que cuando se llama a PostAndReply que necesita para darle una función que:

• construye un mensaje de tipo 'Msg (para ser enviado a el agente)
• después de que F # runtime crea un canal para enviar mensajes a la persona que llama (los canales se representan como valores de tipo AsyncReplyChannel<'Reply>).

El mensaje que construye necesita contener el canal de respuesta, pero la biblioteca F # no sabe cómo quiere representar sus mensajes (y no sabe cómo desea almacenar el canal de respuesta en el mensaje) Como resultado, la biblioteca le pide que escriba una función que construirá el mensaje para el agente después de que el sistema construya el canal.

Su sugerencia alternativa
El problema con su sugerencia es que si PostAndReply tenían un tipo 'Msg -> 'Reply, el mensaje de que el agente recibe después de que se llama Receive sería del siguiente tipo:

'Msg * AsyncReplyChannel<'Reply> 

. .. por lo que cada mensaje recibido por el agente también debería llevar un canal para enviar respuestas. Sin embargo, probablemente no desee enviar una respuesta por cada mensaje recibido, por lo que esto no funcionaría realmente. Tal vez usted podría utilizar algo como:

'Msg * option<AsyncReplyChannel<'Reply>> 

... pero eso es sólo conseguir más complicado (y todavía no esta del todo bien, ya que sólo puede responder a algunos mensajes de 'Msg, pero no a todas ellas)