MailboxProcessor ed eccezioni

Question

Mi chiedo, perché la strategia predefinita di gestione di MailboxProcessor di gestire le eccezioni è semplicemente ignorare in modo invisibile. Ad esempio:

let counter = 
    MailboxProcessor.Start(fun inbox -> 
     let rec loop() = 
      async { printfn "waiting for data..." 
        let! data = inbox.Receive() 
        failwith "fail" // simulate throwing of an exception 
        printfn "Got: %d" data 
        return! loop() 
      } 
     loop()) 
() 
counter.Post(42) 
counter.Post(43) 
counter.Post(44) 
Async.Sleep 1000 |> Async.RunSynchronously 

e non succede nulla. Non vi è alcun arresto irreversibile nell'esecuzione del programma, oppure viene visualizzata una finestra di messaggio con "Un'eccezione non gestita". Niente.

Questa situazione peggiora se qualcuno utilizza il metodo PostAndReply: un deadlock garantito come risultato.

Eventuali motivi per tale comportamento?

Answer 1

Penso che il motivo per cui lo MailboxProcessor in F # non contenga alcun meccanismo per la gestione delle eccezioni è che non è chiaro quale sia il modo migliore per farlo. Ad esempio, potrebbe essere necessario avere un evento globale che viene attivato quando si verifica un'eccezione non gestita, ma è possibile che si desideri rilanciare l'eccezione alla prossima chiamata a Post o PostAndReply.

Entrambe le opzioni possono essere implementate in base allo standard MailboxProcessor, quindi è possibile aggiungere il comportamento desiderato. Ad esempio, il seguente snippet mostra HandlingMailbox che aggiunge un gestore di eccezioni globale. Ha la stessa interfaccia come normale MailboxProcessor (ho omesso alcuni metodi), ma aggiunge OnError evento che viene attivato quando un'eccezione accade:

type HandlingMailbox<'T> private(f:HandlingMailbox<'T> -> Async<unit>) as self = 
    let event = Event<_>() 
    let inbox = new MailboxProcessor<_>(fun inbox -> async { 
    try 
     return! f self 
    with e -> 
     event.Trigger(e) }) 
    member x.OnError = event.Publish 
    member x.Start() = inbox.Start() 
    member x.Receive() = inbox.Receive() 
    member x.Post(v:'T) = inbox.Post(v) 
    static member Start(f) = 
    let mbox = new HandlingMailbox<_>(f) 
    mbox.Start() 
    mbox 

Per usarlo, si potrebbe scrivere lo stesso codice come quello che hai scritto prima , ma ora è possibile gestire le eccezioni in modo asincrono:

let counter = HandlingMailbox<_>.Start(fun inbox -> async { 
    while true do 
    printfn "waiting for data..." 
    let! data = inbox.Receive() 
    failwith "fail" }) 

counter.OnError.Add(printfn "Exception: %A") 
counter.Post(42) 

Answer 2

C'è un evento Error sul MailboxProcessor.

http://msdn.microsoft.com/en-us/library/ee340481

counter.Error.Add(fun e -> printfn "%A" e) 

Naturalmente, si può fare qualcosa di simile soluzione Tomas' se si vuole esercitare un controllo accurato da soli.