실패 후 MailboxProcessor를 다시 시작 하시겠습니까?

Question

MailboxProcessor<'Msg> 클래스를 통해 F #의 상담원과 작업을 시작하려고하는데 예외에 대한 적절한 처리가 없다는 것을 알게되었습니다. 하스켈 세계에서는 어떤 예외도 없으므로 문제를 처리하는 적절한 방법은 단순히 응답 사례로 제공하는 것입니다. 다음 에이전트의 .PostAndReply 메소드를 호출하고 InvalidData 데이터가 유효하지 않은 이유를 나타내는 메시지를 포함 얻을 수

type AgentResponse = 
    | HandledData of string 
    | InvalidData of string 

하나 : 그래서 에이전트는 같은 회신 할 수있다. 그러나 이것은 하스켈이 아니며 때때로 예외가 발생합니다.

let agent = 
    new MailboxProcessor<string * AsyncReplyChannel<AgentResponse>>(fun inbox -> 
     async { 
      while true do 
       let! (msg, replyChannel) = inbox.Receive() 
       if msg = "die" then failwith "Unknown exception encountered!" 
       else replyChannel.Reply(HandledData(msg)) 
     }) 

agent.Start() 
agent.PostAndReply (fun rc -> "die", rc) 
agent.PostAndReply (fun rc -> "Test", rc) 

두 번째 호출 agent.PostAndReply에 블록 무기한 :이 이렇게한다면. AsyncReplyChannel을 사용하지 않고 따라서 agent.Post을 호출하면 호출이 차단되지 않지만 에이전트에서 예외가 발생하면 새 메시지가 대기열에 남아 있습니다. 다시 호출 할 때 agent.Start 함수가 InvalidOperationException을 반환하기 때문에이 두 경우 모두에서 에이전트를 다시 시작할 수 없으며이를 처리하는 자연스러운 방법은 깨끗한 상태의 새 에이전트를 만드는 것이지만 대기중인 모든 메시지는 손실됩니다.

상담원의 전체 본문을 try..with에 배치하는 것 외에도 예외 발생 후 에이전트를 계속 실행하는 좋은 방법이 있습니까? 다른 방법으로, 이것을 다루는 "표준"방법이 누군가가 나를 가리킬 수 있도록 설립 되었습니까? .... ghci에서 Data.List.head []을 시도

불행하게도 종속 유형의 부족을 의미, 우리가 어떤 계산 의미가 없다 타입 올바른 코드를 쓸 수 있는지, 하스켈 또는 F에 # :

Answer 1

당신은 하스켈에서 예외가 않습니다.

실제로는 try ... with 블록을 사용하여 예외를 처리하는 것은 좋지 않습니다. 당신은 몸 전체를 감쌀 필요는 없으며 코드의 순수하지 않은 부분 만 감쌀 수 있습니다.

그러면 고전적으로 적절한 생성자를 사용하여 만든 값을 반환합니다. ,이 시작하고 정상적인 MailboxProcessor처럼 실행할 수 있습니다

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

:

Answer 2

한 가지 가능한 옵션은 반복 에이전트의 몸을 실행 this question에서 토마스 Petricek 이상에 의해 정의 된 HandlingMailbox 유사한 도우미 유형입니다 제공된 에이전트 본문에서 예외가 발생하면 자체적으로 다시 실행됩니다.

편집 : MailboxProcessor 내부 블록을 while true do.. 블록과 비교하여 재귀 함수를 사용하도록 변경하십시오. 이전 코드는 대상 함수가 정상적으로 반환 될 때 실행을 멈추지 않습니다.