Merge pull request #666 from devlights:add-async-helloworld2

Add examples/helloworld/async2 example

Author: devlights

examples/advanced/zeromemorycopy/string2byteslice.go

@@ -3,7 +3,6 @@ package zeromemorycopy
 import (
 	"fmt"
 	"io"
-	"reflect"
 	"strconv"
 	"strings"
 	"time"
@@ -52,8 +51,10 @@ func StringToByteSlice() error {
 	// メモリコピー無しで変換
 	// -------------------------------------
 	elapsed = times.Stopwatch(func(start time.Time) {
-		io.Discard.Write(unsafe.Slice((*byte)(unsafe.Pointer((*reflect.StringHeader)(unsafe.Pointer(&s)).Data)), len(s)))
+		// reflect.StringHeader は、Go 1.20 で deprecated となった
+		io.Discard.Write(unsafe.Slice(unsafe.StringData(s), len(s)))
 
+		//io.Discard.Write(unsafe.Slice((*byte)(unsafe.Pointer((*reflect.StringHeader)(unsafe.Pointer(&s)).Data)), len(s)))
 		/* 上を細かく区切ると以下のようになる
 		var (
 			ptrStr     = unsafe.Pointer(&s)

examples/basic/helloworld/README.md

@@ -6,4 +6,5 @@
 |----|------------|----|
 |sync.go|helloworld_sync|GO言語でのHelloWorldサンプル (同期版)|
 |async.go|helloworld_async|GO言語でのHelloWorldサンプル (非同期版)|
+|async2.go|helloworld_async2|GO言語でのHelloWorldサンプル (非同期版)(2)|
 |mixed.go|helloworld_mixed|同期と非同期の両方で同じことをするサンプル|

examples/basic/helloworld/async2.go

@@ -0,0 +1,109 @@
+package helloworld
+
+import (
+	"fmt"
+	"log"
+	"math/rand"
+	"sync"
+	"time"
+)
+
+const (
+	LoopCount = 20
+)
+
+type _runner struct {
+	name  string
+	wg    *sync.WaitGroup
+	ch    chan<- string
+	delay func() time.Duration
+}
+
+func newRunner(name string, wg *sync.WaitGroup, ch chan<- string, delay func() time.Duration) *_runner {
+	r := new(_runner)
+
+	r.name = name
+	r.wg = wg
+	r.ch = ch
+	r.delay = delay
+
+	return r
+}
+
+func (me *_runner) String() string {
+	return me.name
+}
+
+func (me *_runner) run() {
+	defer me.wg.Done()
+	for i := 0; i < LoopCount; i++ {
+		d := me.delay()
+		time.Sleep(d)
+		me.ch <- fmt.Sprintf("%d:%s (%v)", i, me, d)
+	}
+}
+
+type _closer struct {
+	wg *sync.WaitGroup
+	ch chan<- string
+}
+
+func newCloser(wg *sync.WaitGroup, ch chan<- string) *_closer {
+	c := new(_closer)
+
+	c.wg = wg
+	c.ch = ch
+
+	return c
+}
+
+func (me *_closer) run() {
+	defer close(me.ch)
+	me.wg.Wait()
+}
+
+type _printer struct {
+	ch <-chan string
+}
+
+func newPrinter(ch <-chan string) *_printer {
+	p := new(_printer)
+	p.ch = ch
+	return p
+}
+
+func (me *_printer) run() {
+	for v := range me.ch {
+		log.Println(v)
+	}
+}
+
+// Async2 -- HelloWorld 非同期版 (2)
+func Async2() error {
+	log.SetFlags(0)
+
+	var (
+		wg    = new(sync.WaitGroup)
+		ch    = make(chan string)
+		delay = func() time.Duration {
+			return time.Duration(rand.Intn(200)) * time.Millisecond
+		}
+	)
+
+	var (
+		hello   = newRunner("hello", wg, ch, delay)
+		world   = newRunner("world", wg, ch, delay)
+		closer  = newCloser(wg, ch)
+		printer = newPrinter(ch)
+	)
+
+	wg.Add(2)
+
+	go hello.run()
+	go world.run()
+	go closer.run()
+
+	printer.run()
+
+	return nil
+}

examples/basic/helloworld/examples.go

@@ -15,5 +15,6 @@ func NewRegister() mapping.Register {
 func (r *register) Regist(m mapping.ExampleMapping) {
 	m["helloworld_sync"] = Sync
 	m["helloworld_async"] = Async
+	m["helloworld_async2"] = Async2
 	m["helloworld_mixed"] = Mixed
 }

examples/basic/helloworld/mixed.go

@@ -25,8 +25,8 @@ func Mixed() error {
 
 	// start tasks
 	var (
-		syncCtx  = sync(procCtx)
-		asyncCtx = async(procCtx)
+		syncCtx  = syncOp(procCtx)
+		asyncCtx = asyncOp(procCtx)
 	)
 
 	// wait until all tasks are completed
@@ -35,7 +35,7 @@ func Mixed() error {
 	return nil
 }
 
-func sync(pCtx context.Context) context.Context {
+func syncOp(pCtx context.Context) context.Context {
 	var (
 		ctx, cxl = context.WithCancel(pCtx)
 	)
@@ -52,7 +52,7 @@ func sync(pCtx context.Context) context.Context {
 	return ctx
 }
 
-func async(pCtx context.Context) context.Context {
+func asyncOp(pCtx context.Context) context.Context {
 	var (
 		ctx, cxl = context.WithCancel(pCtx)
 		tasks    = make([]context.Context, 0)