Download framework here.
All posts are here:
- Part I - Workers and ParallelWorkers
- Part II - Agents and control messages
- Part III - Default error management
- Part IV - Custom error management
- Part V - Timeout management
- Part VI - Hot swapping of code
- Part VII - An auction framework
- Part VIII – Implementing MapReduce (user model)
- Part IX – Counting words …
Timeouts are very important in message based systems. In essence, if you are not getting messages for a certain period of time, that usually means something. It might be that something crashed, that other agents think that you are not online, or any other number of things. Hence the need to set timeouts and react when they are triggered.
You do that by writing the following:
counter1 <--SetTimeoutHandler 1000
(fun state -> printfn "I'm still waiting for a message in state %A, come on ..."
Which generates the following message every second:
**I’m still waiting for a message in state 2, come on
I’m still waiting for a message in state 2, come on .…**
The first parameter to SetTimeoutHandler is how long to wait before triggering the handler. The second parameter is the handler that gets called whenever no message is received for that amount of time. Notice that the handler takes the current state of the agent and returns ContinueProcessing(state). This tells the agent to continue processing messages and sets the current state to state.
The following code:
counter1 <-- 2
**I’m still waiting for a message in state 4, come on
I’m still waiting for a message in state 4, come on**
ContinueProcessing is just one of the three possible values of the (terribly named) AfterError:
type AfterError = | ContinueProcessing of obj | StopProcessing | RestartProcessing
Let’s see what RestartProcessing does.
counter1 <-- SetTimeoutHandler 1000 (fun state -> printfn "Restart from state %A" state
Which, as expected, generates a nice stream of:
**Restart from state 0
Restart from state 0**
To bring things back to normal (aka no timeout) you can just pass –1 as in:
counter1 <-- SetTimeoutHandler -1 (fun state -> ContinueProcessing(state))
Also, you can stop the agent when a timeout occurs by returning the aptly named StopProcessing:
counter1 <-- SetTimeoutHandler 1000 (fun state -> printfn "Restart from state %A" state;
Another interesting thing you might want to do is hot swapping of code. More on that in the next part …