Added test run to pipeline; added more output

Signed-off-by: Patrick Eschenbach <patrickeschenbach96@gmail.com>

Author: qcserestipy

.github/workflows/go.yml

@@ -25,4 +25,4 @@ jobs:
       run: go build -o ./bin/pi cmd/example/main.go
 
     - name: Perform Test run
-      run: ./bin/pi
+      run: ./bin/pi -n 10000000000

cmd/example/main.go

@@ -1,44 +1,92 @@
 package main
 
 import (
-	"fmt"
+	"flag"
+	"math"
 	"math/rand"
 	"runtime"
 	"time"
 
 	"github.com/qcserestipy/gohpc/pkg/workerpool"
+	"github.com/sirupsen/logrus"
 )
 
+func init() {
+	formatter := &logrus.TextFormatter{}
+	formatter.FullTimestamp = true
+	formatter.TimestampFormat = time.RFC3339
+	logrus.SetLevel(logrus.DebugLevel)
+	logrus.SetFormatter(formatter)
+}
+
 func main() {
-	const nTests = 10_000_000_000
+	logrus.Info("Starting Monte Carlo π approximation")
+	numbPtr := flag.Int("n", 10000000000, "Number of Trials")
+	flag.Parse()
+	nTests := *numbPtr
+	logrus.Infof("Number of Trials: %d", nTests)
 
 	// Split work into tasks
 	numWorkers := runtime.NumCPU()
+	logrus.Infof("System: %d CPU cores available", numWorkers)
+
 	type Task struct{ Count int }
 	tasks := make([]Task, numWorkers)
 	chunk := nTests / numWorkers
+	remainder := nTests % numWorkers
+
+	var totalAllocated int
 	for i := range tasks {
-		tasks[i] = Task{Count: chunk}
+		extraPoints := 0
+		if i < remainder {
+			extraPoints = 1
+		}
+		tasks[i] = Task{Count: chunk + extraPoints}
+		totalAllocated += tasks[i].Count
 	}
 
+	logrus.WithFields(logrus.Fields{
+		"workers":         numWorkers,
+		"points_per_task": chunk,
+		"remainder":       remainder,
+		"total_allocated": totalAllocated,
+	}).Info("Work distribution prepared")
+
+	setupStart := time.Now()
 	// Create pool
 	pool := workerpool.New[Task, float64](numWorkers)
+	logrus.Infof("Worker pool initialized in %v", time.Since(setupStart))
 
 	// Define work
 	work := func(t Task) float64 {
+		taskStart := time.Now()
 		inCircle := 0
-		r := rand.New(rand.NewSource(time.Now().UnixNano()))
+		seed := time.Now().UnixNano()
+		r := rand.New(rand.NewSource(seed))
+		logrus.Debugf("Worker started with seed %d for %d points", seed, t.Count)
+
 		for i := 0; i < t.Count; i++ {
 			x, y := r.Float64(), r.Float64()
 			if x*x+y*y < 1 {
 				inCircle++
 			}
 		}
+
+		ratio := float64(inCircle) / float64(t.Count)
+		logrus.WithFields(logrus.Fields{
+			"points_processed": t.Count,
+			"points_in_circle": inCircle,
+			"local_ratio":      ratio,
+			"local_pi_approx":  4 * ratio,
+			"duration":         time.Since(taskStart),
+		}).Debug("Worker completed")
+
 		return float64(inCircle)
 	}
 
 	// Run
 	start := time.Now()
+	logrus.Info("Starting computation...")
 	results := pool.Run(tasks, work)
 	elapsed := time.Since(start)
 
@@ -49,5 +97,13 @@ func main() {
 	}
 	piApprox := 4 * (total / float64(nTests))
 
-	fmt.Printf("π ≈ %0.8f (computed in %s)", piApprox, elapsed)
+	logrus.WithFields(logrus.Fields{
+		"pi_approximation": piApprox,
+		"error":            math.Abs(piApprox - math.Pi),
+		"duration":         elapsed,
+		"points_per_sec":   float64(nTests) / elapsed.Seconds(),
+	}).Info("Computation completed")
+
+	logrus.Infof("π ≈ %0.8f (error: %0.8f, computed in %s)",
+		piApprox, math.Abs(piApprox-math.Pi), elapsed)
 }

go.mod

@@ -1,3 +1,8 @@
 module github.com/qcserestipy/gohpc
 
 go 1.23.7
+
+require (
+	github.com/sirupsen/logrus v1.9.3 // indirect
+	golang.org/x/sys v0.0.0-20220715151400-c0bba94af5f8 // indirect
+)

go.sum

@@ -0,0 +1,11 @@
+github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
+github.com/sirupsen/logrus v1.9.3 h1:dueUQJ1C2q9oE3F7wvmSGAaVtTmUizReu6fjN8uqzbQ=
+github.com/sirupsen/logrus v1.9.3/go.mod h1:naHLuLoDiP4jHNo9R0sCBMtWGeIprob74mVsIT4qYEQ=
+github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
+github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
+golang.org/x/sys v0.0.0-20220715151400-c0bba94af5f8 h1:0A+M6Uqn+Eje4kHMK80dtF3JCXC4ykBgQG4Fe06QRhQ=
+golang.org/x/sys v0.0.0-20220715151400-c0bba94af5f8/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
+gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=