MailboxProcessor.PostAndReply < "Msg," odpowiedzi > Metoda (F#)
Ogłoszenia wiadomości agenta i poczekać na odpowiedź na kanale, synchronicznie.
Ścieżka obszaru nazw/modułu: Microsoft.FSharp.Control
Zestaw: FSharp.Core (w FSharp.Core.dll)
// Signature:
member this.PostAndReply : (AsyncReplyChannel<'Reply> -> 'Msg) * ?int -> 'Reply
// Usage:
mailboxProcessor.PostAndReply (buildMessage)
mailboxProcessor.PostAndReply (buildMessage, timeout = timeout)
Parametry
buildMessage
Typ: AsyncReplyChannel<'Reply> -> 'MsgWłączenie funkcji AsyncReplyChannel na wysłanie wiadomości.
timeout
Typ: intParametr opcjonalny limit czasu (w milisekundach) oczekiwania na odpowiedź.Wartością domyślną jest -1, która odpowiada Infinite.
Wartość zwracana
Odpowiedź od agenta.
Uwagi
Wiadomość jest generowany przez zastosowanie buildMessage do nowego kanału odpowiedzi, należy włączyć do wiadomości.Zleceniodawca musi przetworzyć tej wiadomości i wywoływać odpowiedź metody na raz dokładnie ten kanał odpowiedzi.
Przykład
Poniższy przykład kodu pokazuje, jak uruchomić agenta procesora skrzynki pocztowej.W tym przykładzie każdy wiersz danych wejściowych z konsoli jest księgowana kolejki wiadomości.Program odczytuje każdej wiadomości i odpowiedzi przy użyciu kanał odpowiedzi.Po odebraniu wiadomości specjalne "Stop", jest wysyłana odpowiedź Stop i zamyka program.
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
Oto przykład sesji.
Platformy
Windows 8, Windows 7, Windows Server 2012 Windows Server 2008 R2
Informacje o wersji
F# Core wersji biblioteki
Obsługiwane: 2.0, 4.0, przenośne