Add PosterAgent and NumberProducer

.gitignore

@@ -431,3 +431,5 @@ $RECYCLE.BIN/
 !.vscode/tasks.json
 !.vscode/launch.json
 !.vscode/extensions.json
+
+.ionide

Makefile

@@ -0,0 +1,5 @@
+.PHONY: format
+
+format:
+	fantomas --recurse --pageWidth 80 .
+

average-agents/Agents.fs

@@ -1,35 +1,67 @@
 module Agents
+
 open System
+open System.Threading
 
 type Stats =
-    { Count: int;
-      Sum: double; }
+    { Count: int
+      Sum: double }
 
 type Msg =
     | Incr of double
     | Fetch of AsyncReplyChannel<Stats>
     | Die
 
 type StatsAgent() =
+
     let agent =
         MailboxProcessor.Start(fun inbox ->
             let rec loop stats =
                 async {
                     let! msg = inbox.Receive()
                     match msg with
                     | Incr(x) ->
-                        return! loop { Count = stats.Count + 1; Sum = stats.Sum + x}
+                        return! loop
+                                    { Count = stats.Count + 1
+                                      Sum = stats.Sum + x }
                     | Fetch(replyChannel) ->
                         replyChannel.Reply(stats)
                         return! loop stats
                     | Die -> return ()
                 }
-            loop { Count = 0; Sum = 0.0 }
-        )
+            loop
+                { Count = 0
+                  Sum = 0.0 })
 
     interface IDisposable with
         member this.Dispose() = this.Die()
 
     member _.Incr(x) = agent.Post(Incr x)
     member _.Fetch() = agent.PostAndReply(Fetch)
-    member _.Die() = agent.Post(Die)
+    member _.Die() = agent.Post(Die)
+
+type NumberProducer =
+    { TotalNumbers: int
+      SleepIntervalMilliseconds: int }
+
+type Poster =
+    { Producers: NumberProducer [] }
+
+type PosterAgent(statsAgent, poster) =
+    let (poster: Poster) = poster
+    let (statsAgent: StatsAgent) = statsAgent
+
+    let produce (id, numberProducer) =
+        async {
+            for i in 1 .. numberProducer.TotalNumbers do
+                statsAgent.Incr(double i)
+                Thread.Sleep(numberProducer.SleepIntervalMilliseconds)
+            printfn "Producer %d finished; Current stats: %A" id
+                (statsAgent.Fetch())
+        }
+
+    member _.Execute() =
+        let producers =
+            [ for id in 0 .. poster.Producers.Length - 1 ->
+                produce (id, poster.Producers.[id]) ]
+        Async.RunSynchronously(Async.Parallel producers) |> ignore

average-agents/Program.fs

@@ -1,12 +1,28 @@
 open System
 open Agents
 
+let measureTime f =
+    let stopWatch = Diagnostics.Stopwatch.StartNew()
+    f()
+    stopWatch.Stop()
+    stopWatch.Elapsed.TotalMilliseconds
+
+let useAgents() =
+    use statsAgent = new StatsAgent()
+
+    let producers =
+        [| { TotalNumbers = 100
+             SleepIntervalMilliseconds = 50 }
+           { TotalNumbers = 200
+             SleepIntervalMilliseconds = 30 } |]
+
+    let poster = { Producers = producers }
+
+    let posterAgent = PosterAgent(statsAgent, poster)
+    posterAgent.Execute()
+
 [<EntryPoint>]
 let main argv =
-    use statsAgent = new StatsAgent()
-    statsAgent.Incr(5.0)
-    statsAgent.Incr(7.0)
-    printfn "%A" (statsAgent.Fetch())
-    statsAgent.Incr(7.0)
-    printfn "%A" (statsAgent.Fetch())
+    let elapsedTime = measureTime useAgents
+    printfn "Program execution took %fms" elapsedTime
     0 // return an integer exit code