Do less progress reporting (#15)

RayTracing.App/Program.fs

@@ -15,7 +15,6 @@ module Program =
     let go (sample : SampleImages) (pngOutput : IFileInfo) (ctx : ProgressContext) =
         let renderTask = ctx.AddTask "[green]Generating image[/]"
         let writeUnorderedTask = ctx.AddTask "[green]Writing unordered pixels[/]"
-        let readTask = ctx.AddTask "[green]Reading in serialised pixels[/]"
         let writeTask = ctx.AddTask "[green]Writing PPM file[/]"
 
         let logFile =
@@ -35,7 +34,6 @@ module Program =
         let maxProgress, image = SampleImages.get sample renderTask.Increment write
         renderTask.MaxValue <- maxProgress / 1.0<progress>
         writeUnorderedTask.MaxValue <- maxProgress / 1.0<progress>
-        readTask.MaxValue <- maxProgress / 1.0<progress>
         writeTask.MaxValue <- maxProgress / 1.0<progress>
 
         let tempOutput, await =
@@ -46,8 +44,7 @@ module Program =
         async {
             do! Async.AwaitTask await
 
-            let! pixelMap =
-                ImageOutput.readPixelMap readTask.Increment tempOutput (Image.rowCount image) (Image.colCount image)
+            let! pixelMap = ImageOutput.readPixelMap tempOutput (Image.rowCount image) (Image.colCount image)
 
             let pixelMap = ImageOutput.assertComplete pixelMap
             do! Png.write true writeTask.Increment pixelMap pngOutput

RayTracing.App/SampleImages.fs

@@ -43,12 +43,14 @@ module SampleImages =
             }
 
         let image =
-            Array.init
+            Seq.init
                 256
                 (fun height ->
-                    let output = Array.init 256 (fun i -> async { return pixelAt height i })
-                    progressIncrement 1.0<progress>
-                    output
+                    async {
+                        let output = Array.init 256 (pixelAt height)
+                        progressIncrement 1.0<progress>
+                        return output
+                    }
                 )
             |> Image.make 256 256
 

RayTracing.Test/TestPpmOutput.fs

@@ -16,24 +16,18 @@ module TestRayTracing =
 
         let image =
             [|
+                [| Colour.Red ; Colour.Green ; Colour.Blue |]
                 [|
-                    async { return Colour.Red }
-                    async { return Colour.Green }
-                    async { return Colour.Blue }
-                |]
-                [|
-                    async {
-                        return
-                            {
-                                Red = 255uy
-                                Blue = 0uy
-                                Green = 255uy
-                            }
+                    {
+                        Red = 255uy
+                        Blue = 0uy
+                        Green = 255uy
                     }
-                    async { return Colour.White }
-                    async { return Colour.Black }
+                    Colour.White
+                    Colour.Black
                 |]
             |]
+            |> Array.map async.Return
             |> Image.make 2 3
 
         let outputFile = fs.Path.GetTempFileName () |> fs.FileInfo.FromFileName
@@ -42,7 +36,7 @@ module TestRayTracing =
 
         async {
             do! Async.AwaitTask await
-            let! pixelMap = ImageOutput.readPixelMap ignore tempOutput (Image.rowCount image) (Image.colCount image)
+            let! pixelMap = ImageOutput.readPixelMap tempOutput (Image.rowCount image) (Image.colCount image)
             let arr = ImageOutput.assertComplete pixelMap
             do! ImageOutput.writePpm false ignore arr outputFile
             return ()

RayTracing/Domain.fs

@@ -1,5 +1,6 @@
 namespace RayTracing
 
+open System.Threading.Tasks
 open RayTracing
 
 [<Measure>]
@@ -8,7 +9,7 @@ type progress
 type Image =
     private
         {
-            Rows : Pixel Async[] seq
+            Rows : Async<Pixel[]> seq
             RowCount : int
             ColCount : int
         }
@@ -19,34 +20,10 @@ module Image =
 
     let colCount i = i.ColCount
 
-    let render (i : Image) : (Pixel * Async<unit>)[] seq =
-        i.Rows
-        |> Seq.map (fun imageRow ->
-            if imageRow.Length <> i.ColCount then
-                failwithf
-                    "Thought the image had %i columns, got a pixel array with %i columns"
-                    i.ColCount
-                    imageRow.Length
+    let render (i : Image) : Pixel[][] Task =
+        i.Rows |> Async.Parallel |> Async.StartAsTask
 
-            let outputRow = Array.zeroCreate<Pixel * Async<unit>> i.ColCount
-
-            let doIt =
-                imageRow
-                |> Array.mapi (fun i p ->
-                    async {
-                        let! pixel = p
-                        let _, a = outputRow.[i]
-                        outputRow.[i] <- pixel, a
-                    }
-                )
-
-            for k in 0 .. i.ColCount - 1 do
-                outputRow.[k] <- Unchecked.defaultof<_>, doIt.[k]
-
-            outputRow
-        )
-
-    let make (rowCount : int) (colCount : int) (pixels : Async<Pixel>[] seq) : Image =
+    let make (rowCount : int) (colCount : int) (pixels : Async<Pixel[]> seq) : Image =
         {
             RowCount = rowCount
             ColCount = colCount

RayTracing/ImageOutput.fs

@@ -1,11 +1,8 @@
 namespace RayTracing
 
 open System
-open System.Collections.Generic
-open System.Collections.Immutable
 open System.IO
 open System.IO.Abstractions
-open System.Text
 open System.Threading.Tasks
 open SkiaSharp
 
@@ -68,13 +65,7 @@ module ImageOutput =
 
         toRet
 
-    let readPixelMap
-        (incrementProgress : float<progress> -> unit)
-        (progress : IFileInfo)
-        (numRows : int)
-        (numCols : int)
-        : Async<Pixel ValueOption[][]>
-        =
+    let readPixelMap (progress : IFileInfo) (numRows : int) (numCols : int) : Async<Pixel ValueOption[][]> =
         let rec go (dict : _[][]) (reader : Stream) =
             let row = consumeAsciiInteger reader
 
@@ -104,8 +95,6 @@ module ImageOutput =
                         dict
                     else
 
-                        incrementProgress 1.0<progress>
-
                         dict.[row].[col] <-
                             ValueSome
                                 {
@@ -141,53 +130,35 @@ module ImageOutput =
 
     let resume
         (incrementProgress : float<progress> -> unit)
-        (soFar : IReadOnlyDictionary<int * int, Pixel>)
         (image : Image)
         (fs : IFileSystem)
         : IFileInfo * Task<unit>
         =
         let tempFile = fs.Path.GetTempFileName () |> fs.FileInfo.FromFileName
 
-        tempFile,
-        task {
-            use outputStream = tempFile.OpenWrite ()
-            use enumerator = image.Rows.GetEnumerator ()
-            let mutable rowNum = 0
+        let task =
+            async {
+                use outputStream = tempFile.OpenWrite ()
+                let! pixels = image.Rows |> Async.Parallel
 
-            while enumerator.MoveNext () do
-
-                let row = enumerator.Current
-
-                let! _ =
+                pixels
+                |> Array.iteri (fun rowNum row ->
                     row
-                    |> Array.mapi (fun colNum pixel ->
-                        backgroundTask {
-                            let! pixel =
-                                match soFar.TryGetValue ((rowNum, colNum)) with
-                                | false, _ -> pixel
-                                | true, v -> async { return v }
-
-                            lock
-                                outputStream
-                                (fun () ->
-                                    writeAsciiInt outputStream rowNum
-                                    outputStream.WriteByte 44uy // ','
-                                    writeAsciiInt outputStream colNum
-                                    outputStream.WriteByte 10uy // '\n'
-                                    outputStream.WriteByte pixel.Red
-                                    outputStream.WriteByte pixel.Green
-                                    outputStream.WriteByte pixel.Blue
-                                )
-
-                            incrementProgress 1.0<progress>
-                            return ()
-                        }
+                    |> Array.iteri (fun colNum pixel ->
+                        writeAsciiInt outputStream rowNum
+                        outputStream.WriteByte 44uy // ','
+                        writeAsciiInt outputStream colNum
+                        outputStream.WriteByte 10uy // '\n'
+                        outputStream.WriteByte pixel.Red
+                        outputStream.WriteByte pixel.Green
+                        outputStream.WriteByte pixel.Blue
                     )
-                    |> Task.WhenAll
 
-                rowNum <- rowNum + 1
-        }
+                    incrementProgress 1.0<progress>
+                )
+            }
 
+        tempFile, Async.StartAsTask task
 
     let writePpm
         (gammaCorrect : bool)
@@ -237,7 +208,7 @@ module ImageOutput =
         (fs : IFileSystem)
         : IFileInfo * Task<unit>
         =
-        resume progressIncrement ImmutableDictionary.Empty image fs
+        resume progressIncrement image fs
 
 [<RequireQualifiedAccess>]
 module Png =
@@ -264,10 +235,10 @@ module Png =
                 let colour = PixelOutput.toSkia gammaCorrect pixels.[row].[pixels.[row].Length - 1]
 
                 img.SetPixel (pixels.[row].Length - 1, row, colour)
-                incrementProgress 1.0<progress>
 
             for row = 0 to pixels.Length - 2 do
                 writeRow row
+                incrementProgress 1.0<progress>
 
             writeRow (pixels.Length - 1)
 

RayTracing/Scene.fs

@@ -208,26 +208,29 @@ module Scene =
         let rowsIter = 2 * maxHeightCoord + 1
         let colsIter = 2 * maxWidthCoord + 1
 
-        1.0<progress> * float (rowsIter * colsIter),
+        1.0<progress> * float rowsIter,
         {
             RowCount = rowsIter
             ColCount = colsIter
             Rows =
-                Array.init
+                Seq.init
                     rowsIter
                     (fun row ->
                         let row = maxHeightCoord - row - 1
 
-                        Array.init
-                            colsIter
-                            (fun col ->
-                                let col = col - maxWidthCoord
+                        async {
+                            let result =
+                                Array.init
+                                    colsIter
+                                    (fun col ->
+                                        let col = col - maxWidthCoord
 
-                                async {
-                                    let ret = renderPixel print s rand camera maxWidthCoord maxHeightCoord row col
-                                    progressIncrement 1.0<progress>
-                                    return ret
-                                }
-                            )
+                                        let ret = renderPixel print s rand camera maxWidthCoord maxHeightCoord row col
+                                        ret
+                                    )
+
+                            progressIncrement 1.0<progress>
+                            return result
+                        }
                     )
         }