inital commit

Author: mridul-sahu

.gitignore

@@ -0,0 +1,2 @@
+.DS_Store
+.idea

fan_in.go

@@ -0,0 +1,9 @@
+package main
+
+func BoringFanIn(chans ... <-chan string) <-chan string {
+	c := make(chan string)
+	for _, v := range chans {
+		go func(<-chan string) { c <- <-v }(v)
+	}
+	return c
+}

fan_in_fixed_arguments.go

@@ -0,0 +1,16 @@
+package main
+
+func BoringFanInFixedArguments(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
+}

fan_out_all.go

@@ -0,0 +1,14 @@
+package main
+
+func FanOutAll(input <-chan string, outs... chan<- string) {
+	go func() {
+		for {
+			msg := <-input
+			for _, out := range outs {
+				go func(o chan<-string) {
+					o <- msg
+				}(out)
+			}
+		}
+	}()
+}

fan_out_any.go

@@ -0,0 +1,13 @@
+package main
+
+func FanOutAny(input <-chan string, out1, out2 chan<- string) {
+	go func() {
+		for {
+			msg := <-input
+			select {
+			case out1 <- msg:
+			case out2 <- msg:
+			}
+		}
+	}()
+}

generator.go

@@ -0,0 +1,19 @@
+package main
+
+import (
+	"fmt"
+	"time"
+)
+
+func BoringGenerator(msg string) <-chan string {
+	c := make(chan string)
+
+	go func(){
+		for i := 0; ; i++ {
+			c <- fmt.Sprintf("%s %d", msg, i)
+			time.Sleep(time.Second)
+		}
+	}()
+
+	return c
+}

ping_pong.go

@@ -0,0 +1,36 @@
+package main
+
+import (
+	"fmt"
+	"time"
+)
+
+type Ball struct {
+	hits int
+}
+
+func PingPong() {
+	table := make(chan *Ball)
+	over := make(chan bool)
+	go player("ping", table, over)
+	go player("pong", table, over)
+
+	table <- new(Ball)
+	time.Sleep(time.Second)
+	over <- true
+	over <- true
+}
+
+func player(name string, table chan *Ball, over <-chan bool) {
+	for {
+		select {
+		case ball := <-table:
+			fmt.Println(name, ball.hits)
+			ball.hits += 1
+			time.Sleep(time.Millisecond * 100)
+			table <- ball
+		case <-over:
+			return
+		}
+	}
+}

receive_till_quit.go

@@ -0,0 +1,14 @@
+package main
+
+import "fmt"
+
+func BoringReceiveTillQuit(input <-chan string, quit <-chan bool) {
+	for {
+		select {
+		case s := <-input: fmt.Print(s)
+		case <-quit:
+			fmt.Print("Oh ok that was nice talk")
+			return
+		}
+	}
+}

send_when_available.go

@@ -0,0 +1,25 @@
+package main
+
+import (
+	"fmt"
+	"time"
+)
+
+type Request struct {
+	query string
+	data chan string
+}
+
+func SendWhenAvailable() chan<-Request {
+	r := make(chan Request)
+
+	go func(r <-chan Request) {
+		for {
+			request := <-r
+			time.Sleep(time.Millisecond * 100)
+			request.data <- fmt.Sprintf("%s is a very intresting question indeed!", request.query)
+		}
+	}(r)
+
+	return r
+}

sequential_fan_in.go

@@ -0,0 +1,43 @@
+package main
+
+import "fmt"
+
+type Message struct {
+	msg string
+	wait chan bool
+}
+
+func BoringSyncedGenerator(msg string) <-chan Message {
+	m := make(chan Message)
+
+	go func() {
+		for i := 0; ; i++ {
+			wait := make(chan bool)
+			m <- Message{msg: fmt.Sprintf("%s %d", msg, i), wait: wait}
+			<-wait
+		}
+	}()
+	return m
+}
+
+func BoringSequentialFanIn(syncedChans... <-chan Message) <-chan string {
+	c := make(chan string)
+
+	go func() {
+		var msgs []Message
+
+		for _, v := range syncedChans {
+			msgs = append(msgs, <-v)
+		}
+
+		for _, v := range msgs {
+			c <- v.msg
+		}
+
+		for _, v := range msgs {
+			v.wait <- true
+		}
+	}()
+
+	return c
+}