WIP parallel processor

safesparrow · safesparrow · commit 7522f8691a56 · 2022-10-22T02:18:27.000+01:00
diff --git a/tests/FSharp.Compiler.Service.Tests2/Program.fs b/tests/FSharp.Compiler.Service.Tests2/Program.fs
@@ -8,6 +8,6 @@ let runCompiler () =
 
 [<EntryPoint>]
 let main _ = 
-    TestDepResolving.TestProject(@"C:\projekty\fsharp\heuristic\tests\FSharp.Compiler.ComponentTests\FSharp.Compiler.ComponentTests.fsproj")
-    // runCompiler ()
+    //TestDepResolving.TestProject(@"C:\projekty\fsharp\heuristic\tests\FSharp.Compiler.ComponentTests\FSharp.Compiler.ComponentTests.fsproj")
+    runCompiler ()
     0
diff --git a/tests/FSharp.Compiler.Service.Tests2/RunCompiler.fs b/tests/FSharp.Compiler.Service.Tests2/RunCompiler.fs
@@ -1,9 +1,41 @@
 ﻿module FSharp.Compiler.Service.Tests.RunCompiler
 
+open System.Collections.Concurrent
+open System.Threading
+open System.Threading.Tasks
 open NUnit.Framework
 
 [<Test>]
 let runCompiler () =
-    let args =
-        System.IO.File.ReadAllLines(@"C:\projekty\fsharp\heuristic\tests\FSharp.Compiler.Service.Tests2\args.txt") |> Array.skip 1
-    FSharp.Compiler.CommandLineMain.main args |> ignore
+    // let args =
+    //     System.IO.File.ReadAllLines(@"C:\projekty\fsharp\heuristic\tests\FSharp.Compiler.Service.Tests2\args.txt") |> Array.skip 1
+    // FSharp.Compiler.CommandLineMain.main args |> ignore
+    
+    let go (idx : int) =
+        printfn $"{idx} start"
+        Thread.Sleep(1000)
+        printfn $"{idx} stop"
+    
+    printfn "start"
+    use q = new BlockingCollection<int>()
+    let work (idx : int) =
+        printfn $"start worker {idx}"
+        q.GetConsumingEnumerable()
+        |> Seq.iter go
+        printfn $"end worker {idx}"
+    let maxParallel = 4
+    printfn "workers"
+    let workers =
+        [|1..maxParallel|]
+        |> Array.map (fun idx -> Task.Factory.StartNew(fun () -> work idx))
+    
+    printfn "adding"
+    for i in [|1..20|] do
+        q.Add(i)
+        Thread.Sleep(300)
+    printfn "CompleteAdding"
+    q.CompleteAdding()
+    printfn "waitall"
+    Task.WaitAll workers
+    printfn "End"
+    ()

Original file line number	Diff line number	Diff line change
`@@ -8,6 +8,6 @@ let runCompiler () =`
`8`	`8`
`9`	`9`	`[<EntryPoint>]`
`10`	`10`	`let main _ =`
`11`		`- TestDepResolving.TestProject(@"C:\projekty\fsharp\heuristic\tests\FSharp.Compiler.ComponentTests\FSharp.Compiler.ComponentTests.fsproj")`
`12`		`- // runCompiler ()`
	`11`	`+ //TestDepResolving.TestProject(@"C:\projekty\fsharp\heuristic\tests\FSharp.Compiler.ComponentTests\FSharp.Compiler.ComponentTests.fsproj")`
	`12`	`+ runCompiler ()`
`13`	`13`	`0`