Merge pull request #917 from devlights/add-ch-buffered-speed-compare

Author: devlights

examples/singleapp/ch_buffered_speed_compare/.gitignore

@@ -0,0 +1 @@
+app

examples/singleapp/ch_buffered_speed_compare/README.md

@@ -0,0 +1,69 @@
+# Result
+
+## Gitpod
+
+```sh
+$ lscpu | grep 'CPU(s):'
+CPU(s):                               16
+NUMA node0 CPU(s):                    0-15
+
+$ task
+task: [default] rm -f ./app
+task: [default] goimports -w main.go
+task: [default] go build -o app main.go
+task: [default] time ./app -loop 500000 -inch 0 -outch 0
+numWorkers=16
+done
+
+real    0m0.537s
+user    0m0.000s
+sys     0m0.000s
+task: [default] time ./app -loop 500000 -inch 500000 -outch 0
+numWorkers=16
+done
+
+real    0m0.419s
+user    0m0.000s
+sys     0m0.000s
+task: [default] time ./app -loop 500000 -inch 500000 -outch 500000
+numWorkers=16
+done
+
+real    0m0.284s
+user    0m0.000s
+sys     0m0.000s
+```
+
+
+## Chromebook
+
+```sh
+$ lscpu | grep 'CPU(s):'
+CPU(s):                               8
+
+$ task
+task: [default] rm -f ./app
+task: [default] goimports -w main.go
+task: [default] go build -o app main.go
+task: [default] time ./app -loop 500000 -inch 0 -outch 0
+numWorkers=8
+done
+
+real    0m1.264s
+user    0m0.000s
+sys     0m0.000s
+task: [default] time ./app -loop 500000 -inch 500000 -outch 0
+numWorkers=8
+done
+
+real    0m1.127s
+user    0m0.000s
+sys     0m0.000s
+task: [default] time ./app -loop 500000 -inch 500000 -outch 500000
+numWorkers=8
+done
+
+real    0m0.403s
+user    0m0.000s
+sys     0m0.000s
+```

examples/singleapp/ch_buffered_speed_compare/Taskfile.yml

@@ -0,0 +1,17 @@
+# https://taskfile.dev
+
+version: '3'
+
+vars:
+  LOOP_CNT: 500000
+  ZERO: 0
+
+tasks:
+  default:
+    cmds:
+      - rm -f ./app
+      - goimports -w main.go
+      - go build -o app main.go
+      - time ./app -loop {{.LOOP_CNT}} -inch {{.ZERO}} -outch {{.ZERO}}
+      - time ./app -loop {{.LOOP_CNT}} -inch {{.LOOP_CNT}} -outch {{.ZERO}}
+      - time ./app -loop {{.LOOP_CNT}} -inch {{.LOOP_CNT}} -outch {{.LOOP_CNT}}

examples/singleapp/ch_buffered_speed_compare/main.go

@@ -0,0 +1,56 @@
+package main
+
+import (
+	"flag"
+	"fmt"
+	"io"
+	"runtime"
+	"sync"
+)
+
+func main() {
+	var (
+		loopcnt = flag.Int("loop", 10000, "loop count")
+		incnt   = flag.Int("inch", 0, "input ch buffer count, 0 is unbuffered")
+		outcnt  = flag.Int("outch", 0, "output ch buffer count, 0 is unbuffered")
+	)
+	flag.Parse()
+
+	var (
+		wg         sync.WaitGroup
+		numWorkers = runtime.GOMAXPROCS(0)
+		in         = make(chan int, *incnt)
+		out        = make(chan string, *outcnt)
+	)
+
+	go func() {
+		defer close(in)
+		for i := range *loopcnt {
+			in <- i
+		}
+	}()
+
+	fmt.Printf("numWorkers=%d\n", numWorkers)
+	wg.Add(numWorkers)
+
+	for i := range numWorkers {
+		go func(id int) {
+			defer wg.Done()
+
+			for j := range in {
+				out <- fmt.Sprintf("[%d] hello world [%d]", id, j)
+			}
+		}(i + 1)
+	}
+
+	go func() {
+		wg.Wait()
+		close(out)
+	}()
+
+	for v := range out {
+		fmt.Fprintln(io.Discard, v)
+	}
+
+	fmt.Println("done")
+}