Update Go-Concurrency-Patterns

Author: tmpbook

Go-Concurrency-Patterns/README.md

@@ -0,0 +1,26 @@
+### Here is the **video**
+
+[Go Concurrency Patterns](https://www.youtube.com/watch?v=f6kdp27TYZs)
+
+### Here is some pic
+
+#### [boring-04.go](boring-04/boring-04.go)
+
+![2>1](images/chan.jpeg)
+
+```go
+func fanIn(input1, input2 <-chan string) <-chan string {
+	c := make(chan string)
+	go func() {
+		for {
+			c <- <-input1
+		}
+	}()
+	go func() {
+		for {
+			c <- <-input2
+		}
+	}()
+	return c
+}
+```

Go-Concurrency-Patterns/boring-00/boring.go

@@ -0,0 +1,18 @@
+package main
+
+import (
+	"fmt"
+	"math/rand"
+	"time"
+)
+
+func main() {
+	boring("boring!")
+}
+
+func boring(msg string) {
+	for i := 0; ; i++ {
+		fmt.Println(msg, i)
+		time.Sleep(time.Duration(rand.Intn(1e3)) * time.Millisecond)
+	}
+}

Go-Concurrency-Patterns/boring-01/generateBoring.go

@@ -0,0 +1,23 @@
+package main
+
+import (
+	"fmt"
+	"math/rand"
+	"time"
+)
+
+func main() {
+	c := make(chan string)
+	go boring("boring!", c)
+	for i := 0; i < 5; i++ {
+		fmt.Printf("you say: %q\n", <-c)
+	}
+	fmt.Println("You're boring; I'm leaving.")
+}
+
+func boring(msg string, c chan string) {
+	for i := 0; ; i++ {
+		c <- fmt.Sprintf("%s %d", msg, i)
+		time.Sleep(time.Duration(rand.Intn(1e3)) * time.Millisecond)
+	}
+}

Go-Concurrency-Patterns/boring-02/generate2Boring.go

@@ -0,0 +1,28 @@
+package main
+
+import (
+	"fmt"
+	"math/rand"
+	"time"
+)
+
+func main() {
+	c := boring("boring!")
+	d := boring("boring!")
+	for i := 0; i < 5; i++ {
+		fmt.Printf("you say: %q\n", <-c)
+		fmt.Printf("you say: %q\n", <-d)
+	}
+	fmt.Println("You're boring; I'm leaving.")
+}
+
+func boring(msg string) <-chan string {
+	c := make(chan string)
+	go func() {
+		for i := 0; ; i++ {
+			c <- fmt.Sprintf("%s %d", msg, i)
+			time.Sleep(time.Duration(rand.Intn(1e3)) * time.Millisecond)
+		}
+	}()
+	return c
+}

Go-Concurrency-Patterns/boring-03/fanInBoring.go

@@ -0,0 +1,41 @@
+package main
+
+import (
+	"fmt"
+	"math/rand"
+	"time"
+)
+
+func main() {
+	c := fanIn(boring("Joe"), boring("Ann"))
+	for i := 0; i < 10; i++ {
+		fmt.Println(<-c)
+	}
+	fmt.Println("You're both boring; I'm leaving.")
+}
+
+func fanIn(input1, input2 <-chan string) <-chan string {
+	c := make(chan string)
+	go func() {
+		for {
+			c <- <-input1
+		}
+	}()
+	go func() {
+		for {
+			c <- <-input2
+		}
+	}()
+	return c
+}
+
+func boring(msg string) <-chan string {
+	c := make(chan string)
+	go func() {
+		for i := 0; ; i++ {
+			c <- fmt.Sprintf("%s %d", msg, i)
+			time.Sleep(time.Duration(rand.Intn(2e3)) * time.Millisecond)
+		}
+	}()
+	return c
+}

Go-Concurrency-Patterns/boring-04/sequence.go

@@ -0,0 +1,54 @@
+package main
+
+import (
+	"fmt"
+	"math/rand"
+	"time"
+)
+
+type Message struct {
+	str  string
+	wait chan bool
+}
+
+func main() {
+	c := fanIn(boring("Joe"), boring("Ann"))
+	for i := 0; i < 5; i++ {
+		msg1 := <-c
+		fmt.Println(msg1.str)
+		msg2 := <-c
+		fmt.Println(msg2.str)
+
+		msg1.wait <- true
+		msg2.wait <- true
+	}
+	fmt.Println("You're both boring; I'm leaving.")
+}
+
+func fanIn(input1, input2 <-chan Message) <-chan Message {
+	c := make(chan Message)
+	go func() {
+		for {
+			c <- <-input1
+		}
+	}()
+	go func() {
+		for {
+			c <- <-input2
+		}
+	}()
+	return c
+}
+
+func boring(msg string) <-chan Message {
+	c := make(chan Message)
+	waitForIt := make(chan bool)
+	go func() {
+		for i := 0; ; i++ {
+			c <- Message{fmt.Sprintf("%s: %d", msg, i), waitForIt}
+			time.Sleep(time.Duration(rand.Intn(2e3)) * time.Millisecond)
+			<-waitForIt
+		}
+	}()
+	return c
+}

Go-Concurrency-Patterns/boring-05/select/select.go

@@ -0,0 +1,18 @@
+package main
+
+import "fmt"
+
+func main() {
+	var c1, c2, c3 chan int
+
+	select {
+	case v1 := <-c1:
+		fmt.Printf("received %v from c1\n", v1)
+	case v2 := <-c2:
+		fmt.Printf("received %v from c2\n", v2)
+	case c3 <- 23:
+		fmt.Printf("sent %v to c3\n", 23)
+	default:
+		fmt.Printf("no one was ready to communicate\n")
+	}
+}

Go-Concurrency-Patterns/boring-05/selectBoring.go

@@ -0,0 +1,41 @@
+package main
+
+import (
+	"fmt"
+	"math/rand"
+	"time"
+)
+
+func main() {
+	c := fanIn(boring("Joe"), boring("Ann"))
+	for i := 0; i < 10; i++ {
+		fmt.Println(<-c)
+	}
+	fmt.Println("You're both boring; I'm leaving.")
+}
+
+func boring(msg string) <-chan string { // Returns receive-only channel of strings.
+	c := make(chan string)
+	go func() { // We launch the goroutine from inside the function.
+		for i := 0; ; i++ {
+			c <- fmt.Sprintf("%s: %d", msg, i)
+			time.Sleep(time.Duration(rand.Intn(2e3)) * time.Millisecond)
+		}
+	}()
+	return c // Return the channel to the caller.
+}
+
+func fanIn(input1, input2 <-chan string) <-chan string {
+	c := make(chan string)
+	go func() {
+		for {
+			select {
+			case s := <-input1:
+				c <- s
+			case s := <-input2:
+				c <- s
+			}
+		}
+	}()
+	return c
+}