新文件： routine/channel.go

新文件：   routine/channel_test.go

routine/channel.go

@@ -0,0 +1,20 @@
+package routine
+
+type Result struct {
+	Key   string
+	Value interface{}
+}
+
+func Channel2Map(c chan Result, m map[string]Result) {
+	for {
+		result := <-c
+		m[result.Key] = result
+	}
+}
+
+func Run(singleThreadFlag *bool, c chan Result, m map[string]Result) {
+	if !*singleThreadFlag {
+		*singleThreadFlag = true
+		go Channel2Map(c, m)
+	}
+}

routine/channel_test.go

@@ -0,0 +1,20 @@
+package routine
+
+import (
+	"github.com/ssst0n3/awesome_libs/log"
+	"testing"
+	"time"
+)
+
+func TestRun(t *testing.T) {
+	var singleThreadFlag bool
+	chanResult := make(chan Result, 10)
+	mapResult := make(map[string]Result)
+	Run(&singleThreadFlag, chanResult, mapResult)
+	chanResult <- Result{
+		Key:   "test",
+		Value: true,
+	}
+	time.Sleep(time.Millisecond*100)
+	log.Logger.Info(mapResult)
+}