1 files changed, 102 insertions, 0 deletions
diff --git a/gochan.go b/gochan.go
new file mode 100644
index 0000000..3f62b24
--- /dev/null
+++ b/gochan.go
@@ -0,0 +1,102 @@
+// https://www.digitalocean.com/community/tutorials/how-to-run-multiple-functions-concurrently-in-go
+// who came up with the idea of making community tutorials. that was a good idea!
+
+package debugger
+
+import (
+	"fmt"
+	"sync"
+
+	"go.wit.com/log"
+	"go.wit.com/gui/gui"
+	"go.wit.com/gui/gadgets"
+)
+
+var debugWG *sync.WaitGroup
+var debugNumberChan chan int
+
+func DebugGoChannels(p *gui.Node) *gadgets.BasicWindow {
+	var w *gadgets.BasicWindow
+	var g *gui.Node
+
+	w = gadgets.NewBasicWindow(p, "Debug GO Channels")
+	g = w.Box().NewGroup("Channel stuff").Pad()
+
+	// var debugWG sync.WaitGroup
+	g.NewButton("init()", func () {
+		if (debugNumberChan == nil) {
+			log.Log(true, "making debugNumberChan channel")
+			debugNumberChan = make(chan int)
+		} else {
+			log.Log(true, "debugNumberChan already made")
+		}
+		debugWG = new(sync.WaitGroup)
+	})
+	g.NewButton("go printInt(x) (read x values off the channel)", func () {
+			debugWG.Add(1)
+			go printInt(2, "routine1")
+			debugWG.Add(1)
+			go printInt(2, "routine2")
+	})
+	g.NewButton("sendNumber(2) (chan <- 2, 4)", func () {
+		debugWG.Add(1)
+		debugWG.Add(1)
+		go sendNumber(2)
+		go sendNumber(4)
+	})
+	g.NewButton("sendNumber(1) (chan <- 7)", func () {
+		debugWG.Add(1)
+		go sendNumber(7)
+	})
+	g.NewButton("send 4 numbers (chan <- int)", func () {
+		log.Log(true, "generateNumbers(4)")
+		go generateNumbers(4)
+	})
+	g.NewButton("debugWG.Done()", func () {
+		log.Log(true, "ran debugWG.Done()")
+		debugWG.Done()
+	})
+	g.NewButton("close chan", func () {
+		log.Log(true, "close() on", debugNumberChan)
+		close(debugNumberChan)
+	})
+	g.NewButton("print", func () {
+		log.Log(true, "waitgroup counter is ?")
+	})
+	return w
+}
+
+func sendNumber(i int) {
+	log.Log(true, "START debugNumberChan <-", i, "  (sending", i, "to channel)")
+	debugNumberChan <- i
+	debugWG.Wait()
+	log.Log(true, "END   debugNumberChan sendNumber() done", i)
+}
+
+func generateNumbers(total int) {
+	fmt.Printf("START generateNumbers()\n")
+	for idx := 1; idx <= total; idx++ {
+		log.Log(true, "ran debugNumberChan <= idx where idx =", idx)
+		fmt.Printf("S generateNumbers() sending %d to channel\n", idx)
+		debugNumberChan <- idx
+		// res, err := (<-r)()
+		fmt.Printf("E generateNumbers() sending %d to channel\n", idx)
+	}
+	debugWG.Wait()
+	fmt.Printf("END   generateNumbers()\n")
+}
+
+// i equals the number of times to read values from the channel
+func printInt(i int, name string) {
+	tmp := 1
+	log.Log(true, "START printInt", name, "read debugNumberChan()")
+	for num := range debugNumberChan {
+		log.Log(true, "printInt()",name, "read", num, "from channel")
+		debugWG.Done()
+		if (tmp == i) {
+			return
+		}
+		tmp += 1
+	}
+	fmt.Printf("END printInt()", name, "read debugNumberChan\n")
+}