<实验><代码实验案例提交>

Author: iceopen

demo/nsq-demo/nsq_producer.go

@@ -1,12 +1,12 @@
 package main
 
 import (
+	"encoding/json"
+	"fmt"
 	"github.com/labstack/echo"
-	"net/http"
 	"github.com/nsqio/go-nsq"
 	"log"
-	"fmt"
-	"encoding/json"
+	"net/http"
 )
 
 type ProBody struct {

labs/default-selection/main.go

@@ -0,0 +1,23 @@
+package main
+
+import (
+	"fmt"
+	"time"
+)
+
+func main() {
+	tick := time.Tick(100 * time.Millisecond)
+	boom := time.After(500 * time.Millisecond)
+	for {
+		select {
+		case <-tick:
+			fmt.Println("tick.")
+		case <-boom:
+			fmt.Println("BOOM!")
+			return
+		default:
+			fmt.Println("    .")
+			time.Sleep(50 * time.Millisecond)
+		}
+	}
+}

labs/goroutine-channel-goroutine/main.go

@@ -0,0 +1,28 @@
+package main
+
+import (
+	"fmt"
+)
+
+func gen() chan int {
+	out := make(chan int)
+	fmt.Println("gen start")
+	go func() {
+		for i := 0; i < 100; i++ {
+			out <- i
+		}
+	}()
+	fmt.Println("gen end")
+	return out
+}
+
+func seq(input chan int) {
+	for num := range input {
+		fmt.Println(num)
+	}
+}
+
+func main() {
+	in := gen()
+	go seq(in)
+}

labs/goroutine-channel-url/main.go

@@ -0,0 +1,35 @@
+package main
+
+import (
+	"fmt"
+	"github.com/astaxie/beego/httplib"
+)
+
+func getUrlBody() chan string {
+	str := make(chan string)
+	fmt.Println("url start")
+	go func() {
+		fmt.Println("httplib start")
+		urlStr, err := httplib.Get("http://httpbin.org/get").String()
+		if err != nil {
+
+		}
+		fmt.Println("httplib end")
+		str <- urlStr
+	}()
+	fmt.Println("url end")
+	return str
+}
+
+func strPrint(input chan string) {
+	for ss := range input {
+		fmt.Println(ss)
+	}
+}
+
+func main() {
+	str := getUrlBody()
+	fmt.Println(str)
+	go strPrint(str)
+	select {}
+}

labs/goroutine/main.go

@@ -2,12 +2,11 @@ package main
 
 import (
 	"fmt"
-	"time"
 )
 
 func say(s string) {
 	for i := 0; i < 5; i++ {
-		time.Sleep(100 * time.Millisecond)
+		//time.Sleep(100 * time.Millisecond)
 		fmt.Println(s)
 	}
 }

labs/goroutine/nogoroutine/main.go

@@ -0,0 +1,28 @@
+package main
+
+import (
+	"fmt"
+	"math/rand"
+	"time"
+)
+
+// demo URL http://blog.teamtreehouse.com/goroutines-concurrency
+func generateKey() int {
+	fmt.Println("Generating key")
+	// Super-secret algorithm!
+	keys := []int{3, 5, 7, 11}
+	key := keys[rand.Intn(len(keys))]
+	// It's kinda slow!
+	time.Sleep(3 * time.Second)
+	fmt.Println("Done generating")
+	return key
+}
+
+func main() {
+	rand.Seed(time.Now().Unix())
+	// Call generateKey 3 times.
+	for i := 0; i < 3; i++ {
+		fmt.Println(generateKey())
+	}
+	fmt.Println("All done!")
+}

labs/goroutine/usegoroutine/main.go

@@ -0,0 +1,39 @@
+package main
+
+import (
+	"fmt"
+	"math/rand"
+	"time"
+)
+
+// Update this function to accept a channel parameter,
+// and remove the return value.
+func generateKey(channel chan int) {
+	fmt.Println("Generating key")
+	keys := []int{3, 5, 7, 11}
+	key := keys[rand.Intn(len(keys))]
+	time.Sleep(3 * time.Second)
+	fmt.Println("Done generating")
+	// Write the key to the channel instead of returning.
+	channel <- key
+}
+
+func main() {
+	rand.Seed(time.Now().Unix())
+	// Create a channel.
+	channel := make(chan int)
+	// Create 3 more goroutines.
+	for i := 0; i < 3; i++ {
+		go generateKey(channel)
+	}
+	// Read and print keys from the channel.
+	// This also causes the program to wait until 3
+	// keys have been read.
+	for i := 0; i < 3; i++ {
+		fmt.Println(<-channel)
+	}
+	//for i := range channel {
+	//	fmt.Println(i)
+	//}
+	fmt.Println("All done!")
+}

labs/select/main.go

@@ -0,0 +1,28 @@
+package main
+
+import "fmt"
+
+func fibonacci(c, quit chan int) {
+	x, y := 0, 1
+	for {
+		select {
+		case c <- x:
+			x, y = y, x+y
+		case <-quit:
+			fmt.Println("quit")
+			return
+		}
+	}
+}
+
+func main() {
+	c := make(chan int)
+	quit := make(chan int)
+	go func() {
+		for i := 0; i < 10; i++ {
+			fmt.Println(<-c)
+		}
+		quit <- 0
+	}()
+	fibonacci(c, quit)
+}