Initial commit

action.go

@@ -0,0 +1,11 @@
+package main
+
+import (
+	"fmt"
+	"time"
+)
+
+func PrintPayload(payload map[string]string) {
+	time.Sleep(time.Second)
+	fmt.Println(payload)
+}

main.go

@@ -0,0 +1,21 @@
+package main
+
+import (
+	"TaskPool/worker"
+	"time"
+)
+
+func main() {
+defer worker.Wait()
+for i :=0; i < 10000000; i++ {
+	job := worker.Job{
+		Action: PrintPayload,
+		Payload: map[string]string{
+			"time": time.Now().String(),
+		},
+	}
+	job.Fire()
+}
+
+time.Sleep(time.Second * 3)
+}

worker/worker.go

@@ -0,0 +1,25 @@
+package worker
+
+import "sync"
+
+var wg sync.WaitGroup
+
+type Job struct {
+	id      string
+	Action  func(map[string]string)
+	Payload map[string]string
+}
+
+func Wait() {
+	wg.Wait()
+}
+
+func (job Job) Fire() {
+	wg.Add(1)
+
+	go func() {
+		defer wg.Done()
+		job.Action(job.Payload)
+	}()
+
+}