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

Crée et démarre un agent.

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

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

// Signature:
static member Start : (MailboxProcessor<'Msg> -> Async<unit>) * ?CancellationToken -> MailboxProcessor<'Msg>

// Usage:
MailboxProcessor.Start (body)
MailboxProcessor.Start (body, cancellationToken = cancellationToken)

Paramètres

• body
  Type : MailboxProcessor<'Msg> -> Async<unit>

  Fonction permettant de produire un calcul asynchrone qui sera exécuté comme boucle de lecture pour le MailboxProcessor lors de l'appel de Start.

• cancellationToken
  Type : CancellationToken

  Jeton d'annulation facultatif pour le body. La valeur par défaut est Async.DefaultCancellationToken.

Valeur de retour

MailboxProcessor créé.

Notes

La fonction body est utilisée pour générer le calcul asynchrone exécuté par l'agent.

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 à l'aide d'un canal de réponse. Lorsque le message spécial d'arrêt est reçu, la réponse d'arrêt 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 7, Windows Vista SP2, Windows XP SP3, Windows XP x64 SP2, Windows Server 2008 R2, Windows Server 2008 SP2, Windows Server 2003 SP2

Informations de version

Runtime F#

Pris en charge dans : 2.0, 4.0

Silverlight

Prise en charge dans : 3

Voir aussi

Référence

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

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

Historique des modifications

Date	Historique	Motif
Janvier 2011	Ajout d'un exemple de code	Améliorations apportées aux informations.