asynchronous call support

go/example_test.go

@@ -0,0 +1,21 @@
+package g_test
+
+import (
+	"fmt"
+	"github.com/name5566/leaf/go"
+)
+
+func Example() {
+	d := g.New(10)
+
+	d.Go(func() {
+		fmt.Print("My name is ")
+	}, func() {
+		fmt.Println("Leaf")
+	})
+
+	d.Close()
+
+	// Output:
+	// My name is Leaf
+}

go/go.go

@@ -0,0 +1,34 @@
+package g
+
+// one Go per goroutine
+type Go struct {
+	ChanCb    chan func()
+	pendingGo int
+}
+
+func New(l int) *Go {
+	g := new(Go)
+	g.ChanCb = make(chan func(), l)
+	return g
+}
+
+func (g *Go) Go(f func(), cb func()) {
+	g.pendingGo++
+
+	go func() {
+		f()
+		g.ChanCb <- cb
+	}()
+}
+
+func (g *Go) Cb(cb func()) {
+	cb()
+
+	g.pendingGo--
+}
+
+func (g *Go) Close() {
+	for g.pendingGo > 0 {
+		g.Cb(<-g.ChanCb)
+	}
+}