通过

MailboxProcessor.Receive<'Msg> 方法 (F#)

  • 项目

等待消息。这将按到达顺序使用第一条消息。

命名空间/模块路径： Microsoft.FSharp.Control

程序集：FSharp.Core（在 FSharp.Core.dll 中）

// Signature:
member this.Receive : ?int -> Async<'Msg>

// Usage:
mailboxProcessor.Receive ()
mailboxProcessor.Receive (timeout = timeout)

参数

  • timeout
    类型：int

    可选超时（以毫秒为单位）。默认值为 -1，它对应于 Infinite。

异常

异常

Condition

TimeoutException

在超过超时的情况下引发。

返回值

一个返回接收到的消息的异步计算（Async 对象）。

备注

此方法可在代理的主体内使用。对于每个代理，至多只有一个并发读线程可处于活动状态，因此不能有多个对 Receive, TryReceive, Scan 或 TryScan 的并发调用处于活动状态。

示例

下面的示例演示如何使用 Receive 方法。在这种情况下，指定了 10 秒的超时。一般情况下，处理函数的消息运行在 Post 函数中的不同线程上，因此您必须捕获消息处理器函数中的超时异常。在此示例中，超时异常只会导致循环继续下去，并按 1 增加消息数量。

open System

type Message = string * AsyncReplyChannel<string>

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

let agent = MailboxProcessor<Message>.Start(fun inbox ->
    let rec loop n =
        async {            
            try
                let! (message, replyChannel) = inbox.Receive(10000);

                if (message = "Stop") then
                    replyChannel.Reply("Stop")
                else
                    replyChannel.Reply(String.Format(formatString, n, message))
                do! loop (n + 1)

            with
            | :? TimeoutException -> 
                printfn "The mailbox processor timed out."
                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()
    let reply = agent.PostAndReply(fun replyChannel -> input, replyChannel)
    if (reply <> "Stop") then
        printfn "Reply: %s" reply
        loop()
    else
        ()
loop()

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

典型的会话遵循。请注意，由于超时，将跳过消息 2。

平台

Windows 8，Windows 7，Windows server 2012中，Windows server 2008 R2

版本信息

F#核心库版本

支持:2.0，4.0，可移植

请参见

参考

Control.MailboxProcessor<'Msg> 类 (F#)

Microsoft.FSharp.Control 命名空间 (F#)