Метод MailboxProcessor.TryReceive<'Msg> (F#)

Статья
08/11/2011

Ожидает сообщение. Будет использовано первое сообщение в порядке поступления.

Пространство имен/путь к модулю: Microsoft.FSharp.Control

Сборка: FSharp.Core (в FSharp.Core.dll)

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

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

Параметры

timeout
Тип: int

Необязательное время ожидания в миллисекундах. По умолчанию устанавливается значение -1, что соответствует значению Infinite().

Возвращаемое значение

Асинхронное вычисление (объект Async), которое возвращает полученное сообщение или значение None, если превышен тайм-аут.

Заметки

Этот метод предназначен для использования в теле агента. Возвращает значение None, если время ожидания задано и превышено. Этот метод предназначен для использования в теле агента. Для каждого агента в каждый момент времени может быть активно только одно средство чтения, поэтому активным может быть только один вызов Receive, TryReceive, Scan или TryScan.

Пример

В следующем примере показано использование TryReceive. Если сообщение не будет получено в течение 10 секунд, время ожидания истекает и идентификатор сообщения увеличивается на 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 {
                let! opt = inbox.TryReceive(10000);
                match opt with
                | None -> do! loop(n + 1)
                | Some (message, replyChannel) ->
                    // The delay gets longer with each message, and eventually triggers a timeout.
                    if (message = "Stop") then
                        replyChannel.Reply("Stop")
                    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 mutable isCompleted = false
while (not isCompleted) do
    printf "> "
    let input = Console.ReadLine()
    let reply = agent.PostAndReply(fun replyChannel -> input, replyChannel)
    if (reply <> "Stop") then
        printfn "Reply: %s" reply
    else
        isCompleted <- true

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

Ниже представлен пример сеанса. Обратите внимание, что сообщение № 2 пропускается из-за истечения времени ожидания.

Платформы

Windows 7, Windows Vista с пакетом обновления 2 (SP2), Windows XP с пакетом обновления 3 (SP3), Windows XP x64 с пакетом обновления 2 (SP2), Windows Server 2008 R2, Windows Server 2008 с пакетом обновления 2 (SP2), Windows Server 2003 с пакетом обновления 2 (SP2)

Сведения о версии

Среда выполнения F#

Поддерживается в версиях 2.0, 4.0

Silverlight

Поддерживается в версии 3

См. также

Ссылки

Класс Control.MailboxProcessor<'Msg> (F#)

Пространство имен Microsoft.FSharp.Control (F#)

Журнал изменений

Дата	Журнал	Причина
Январь 2011	Добавлен пример кода.	Улучшение информации.

Январь 2011

Добавлен пример кода.

Улучшение информации.

Поделиться через