第１１回の課題（大倉）

channel/task/basic/main.go

@@ -1,6 +1,28 @@
 package main
 
-// channel/basicのInt版
+import (
+	"fmt"
+	"math/rand"
+	"time"
+)
+
 // Goroutine内で好きなIntをchannelを経由でMain Goroutineに渡し標準出力にPrintしてみる。
 func main() {
+	ch := make(chan int)
+
+	go func() {
+		defer close(ch)
+
+		rand.Seed(time.Now().Unix())
+		max := rand.Intn(10)
+
+		for i := 0; i < max; i++ {
+			time.Sleep(1 * time.Second)
+			ch <- rand.Intn(100)
+		}
+	}()
+
+	for v := range ch {
+		fmt.Printf("revieved: %d\n", v)
+	}
 }

channel/task/sleep_sort/main.go

@@ -1,4 +1,35 @@
 package main
 
+import (
+	"fmt"
+	"time"
+)
+
 func main() {
+	nums := []int{1, 3, 2, 5, 4}
+
+	sortedNumbersChan := sortedNumbersChan(nums)
+
+	for n := range sortedNumbersChan {
+		fmt.Println(n)
+	}
+}
+
+func sortedNumbersChan(nums []int) <-chan int {
+	ch := make(chan int)
+
+	for _, num := range nums {
+		isLast := num == len(nums)
+
+		go func(n int, isLast bool) {
+			if isLast {
+				defer close(ch)
+			}
+
+			time.Sleep(time.Duration(n) * time.Second)
+			ch <- n
+		}(num, isLast)					
+	}
+
+	return ch
 }

channel/task/ticker/main.go

@@ -1,4 +1,43 @@
 package main
 
+import (
+	"fmt"
+	"time"
+)
+
 func main() {
+	fmt.Println("+++++ Metronome is start +++++")
+
+	bpm := 120
+
+	// metronomeCh := metronomeChan(120)
+	doneCh := make(chan interface{})
+
+	waitSpan := time.Duration(60 * 1000 / bpm)
+	flag := 0
+	ticker := time.NewTicker(waitSpan * time.Millisecond)
+	defer ticker.Stop()
+
+	go func() {
+		time.Sleep(5 * time.Second)
+		doneCh <- "5 second timeout"
+	}()
+
+loop:
+	for {
+		select {
+		case <-ticker.C:
+			if flag == 0 {
+				fmt.Println("tic")
+				flag = 1
+			} else {
+				fmt.Println("tac")
+				flag = 0
+			}
+		case v := <-doneCh:
+			fmt.Println(v)
+			break loop
+		}
+	}
+	fmt.Println("+++++ Metronome is end +++++")
 }