testing

kyaxcorp · Sep 5, 2023 · bd0725c · bd0725c
1 parent 24bc8c3
commit bd0725c
Show file tree

Hide file tree

Showing 2 changed files with 70 additions and 0 deletions.
diff --git a/testing/channels/channel_async_buffer/main.go b/testing/channels/channel_async_buffer/main.go
@@ -0,0 +1,35 @@
+package main
+
+import (
+	"github.com/google/uuid"
+	"log"
+	"time"
+)
+
+func main() {
+
+	myChannel := make(chan uuid.UUID, 2)
+
+	go func() {
+		for {
+			select {
+			case data := <-myChannel:
+				log.Println(data, "sleeping... 3 sec")
+				time.Sleep(time.Second * 3)
+			}
+		}
+	}()
+
+	for i := 0; i <= 3; i++ {
+		id, _ := uuid.NewRandom()
+		log.Println("pushing", id)
+		//go func() {
+		myChannel <- id
+		//}()
+		log.Println("pushed", id)
+	}
+
+	log.Println("finished pushing data to channel")
+
+	time.Sleep(time.Second * 10)
+}
diff --git a/testing/channels/channel_async_buffer2/main.go b/testing/channels/channel_async_buffer2/main.go
@@ -0,0 +1,35 @@
+package main
+
+import (
+	"github.com/google/uuid"
+	"log"
+	"time"
+)
+
+func main() {
+
+	myChannel := make(chan uuid.UUID, 2)
+
+	go func() {
+		for {
+			select {
+			case data := <-myChannel:
+				log.Println(data, "sleeping... 3 sec")
+				time.Sleep(time.Second * 3)
+			}
+		}
+	}()
+
+	for i := 0; i <= 3; i++ {
+		id, _ := uuid.NewRandom()
+		log.Println("pushing", id)
+		go func() {
+			myChannel <- id
+		}()
+		log.Println("pushed", id)
+	}
+
+	log.Println("finished pushing data to channel")
+
+	time.Sleep(time.Second * 10)
+}