Merge pull request #667 from devlights:add-helloworld-async3

Add helloworld_async3

Author: devlights

examples/basic/helloworld/async3/async3.go

@@ -0,0 +1,55 @@
+package async3
+
+import (
+	"log"
+	"math/rand"
+	"time"
+)
+
+var (
+	count = 20
+	delay = func() time.Duration {
+		return time.Duration(rand.Intn(200)) * time.Millisecond
+	}
+)
+
+// Async3 -- HelloWorld 非同期版 (3)
+func Async3() error {
+	log.SetFlags(0)
+
+	var (
+		hello = newRunner("hello", count, delay)
+		world = newRunner("world", count, delay)
+	)
+
+	hello.run()
+	world.run()
+
+	var (
+		h   string
+		w   string
+		hOk = true
+		wOk = true
+	)
+
+	for {
+		select {
+		case h, hOk = <-hello.ch:
+			if !hOk {
+				break
+			}
+			log.Println(h)
+		case w, wOk = <-world.ch:
+			if !wOk {
+				break
+			}
+			log.Println(w)
+		}
+
+		if !hOk && !wOk {
+			break
+		}
+	}
+
+	return nil
+}

examples/basic/helloworld/async3/runner.go

@@ -0,0 +1,40 @@
+package async3
+
+import (
+	"fmt"
+	"time"
+)
+
+type _runner struct {
+	name  string
+	ch    chan string
+	count int
+	delay func() time.Duration
+}
+
+func newRunner(name string, count int, delay func() time.Duration) *_runner {
+	r := new(_runner)
+
+	r.name = name
+	r.ch = make(chan string)
+	r.count = count
+	r.delay = delay
+
+	return r
+}
+
+func (me *_runner) run() {
+	go func() {
+		defer close(me.ch)
+
+		for i := 0; i < me.count; i++ {
+			d := me.delay()
+			time.Sleep(d)
+			me.ch <- fmt.Sprintf("%d:%s (%v)", i, me, d)
+		}
+	}()
+}
+
+func (me *_runner) String() string {
+	return me.name
+}

examples/basic/helloworld/examples.go

@@ -2,6 +2,7 @@ package helloworld
 
 import (
 	"github.com/devlights/try-golang/examples/basic/helloworld/async2"
+	"github.com/devlights/try-golang/examples/basic/helloworld/async3"
 	"github.com/devlights/try-golang/mapping"
 )
 
@@ -19,5 +20,6 @@ func (r *register) Regist(m mapping.ExampleMapping) {
 	m["helloworld_sync"] = Sync
 	m["helloworld_async"] = Async
 	m["helloworld_async2"] = async2.Async2
+	m["helloworld_async3"] = async3.Async3
 	m["helloworld_mixed"] = Mixed
 }