MailboxProcessor.PostAndReply<'Msg,'Reply> Yöntemi (F#)

Makale
02/28/2013

Aracıya bir ileti gönderir ve zaman uyumlu olarak kanal üzerinde bir cevap bekler.

Ad alanı/modül yolu: Microsoft.FSharp.Control

Derleme: FSharp.Core (FSharp.Core.dll),

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

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

Parametreler

buildMessage
Türü: AsyncReplyChannel<'Reply> -> 'Msg

Birleştirmek için işlev AsyncReplyChannel iletisinin gönderilmesi halinde.
timeout
Türü: int

Bir yanıt iletisi için beklenecek isteğe bağlı zaman aşımı parametresi (milisaniye cinsinden). Karşılık gelen -1 varsayılandır Infinite.

Dönüş Değeri

Aracının yanıtı.

Notlar

İleti, mesaja eklemek üzere yeni bir yanıt kanalına buildMessage uygulayarak oluşturulur. Alıcı Aracısı bu iletiyi işlemek ve harekete geçirmek yanıt yöntemi kanalında bu yanıtı tam olarak bir kez.

Örnek

Aşağıdaki kod örneği, bir posta kutusu işlemci Aracısı Başlat gösterilmiştir. Bu örnekte, bir ileti sırası konsoldan giriş metnin her satırının deftere nakledilir. Program, her iletiyi okur ve bir yanıt kanalı kullanarak yanıtlar. "Dur" özel ileti alındığında, Dur yanıt gönderilir ve programından çıkar.

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

Aşağıdaki örnek bir oturumdur.

Platformlar

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

Sürüm Bilgisi

F# Çekirdek Kitaplığı sürümleri

Desteklenen: 2.0, 4.0, Portable

Ayrıca bkz.

Başvuru

Control.MailboxProcessor<'Msg> Sınıfı (F#)

Microsoft.FSharp.Control İsim Uzayı (F#)

Aracılığıyla paylaş