MailboxProcessor.PostAndReply<'Msg,'Reply>, méthode (F#)

Article
06/10/2015

Publie un message à un agent et attend une réponse sur le canal, de façon synchrone.

Espace de noms/Chemin du module : Microsoft.FSharp.Control

Assembly : FSharp.Core (in FSharp.Core.dll)

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

// Usage:
mailboxProcessor.PostAndReply (buildMessage)
mailboxProcessor.PostAndReply (buildMessage, timeout = timeout)

Paramètres

buildMessage
Type : AsyncReplyChannel<'Reply> -> 'Msg

Fonction permettant d'incorporer AsyncReplyChannel dans le message à envoyer.
timeout
Type : int

Paramètre de délai d'attente facultatif (en millisecondes) d'un message de réponse. Valeur par défaut de -1, qui correspond à Infinite.

Valeur de retour

Réponse de l'agent.

Notes

Le message est généré en appliquant buildMessage à un nouveau canal de réponse à incorporer dans le message. L'agent de réception doit traiter ce message et appeler précisément la méthode Reply une fois sur ce canal de réponse.

Exemple

L'exemple de code suivant montre comment démarrer un agent de processeur de boîte aux lettres. Dans cet exemple, chaque ligne d'entrée de la console est publiée dans une file d'attente de messages. Le programme lit chaque message et répond via un canal de réponse. Lorsque le message spécial « Stop » est reçu, la réponse Stop est envoyée et le programme prend fin.

open System

type Message = string * AsyncReplyChannel<string>

let formatString = "Message number {0} was received. Message contents: {1}" 

let printThreadId note =

    // Append the thread ID.
    printfn "%d : %s" System.Threading.Thread.CurrentThread.ManagedThreadId note


let agent = MailboxProcessor<Message>.Start(fun inbox ->
    let rec loop n =
        async {
                let! (message, replyChannel) = inbox.Receive();
                printThreadId "MailboxProcessor" 
                if (message = "Stop") then
                    replyChannel.Reply("Stopping.")
                else
                    replyChannel.Reply(String.Format(formatString, n, message))
                do! loop (n + 1)
        }
    loop 0)

printfn "Mailbox Processor Test"
printfn "Type some text and press Enter to submit a message."
printfn "Type 'Stop' to close the program." 

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()

printfn "Press Enter to continue."
Console.ReadLine() |> ignore

Voici un exemple de session.

Plateformes

Windows 8, Windows 7, Windows Server 2012, Windows Server 2008 R2

Informations sur la version

Version de bibliothèque principale F#

Prise en charge dans : 2.0, 4.0, portables

Voir aussi

Référence

Control.MailboxProcessor<'Msg>, classe (F#)

Microsoft.FSharp.Control, espace de noms (F#)

Partager via