处理任务系统

mlogclub · Jan 17, 2022 · bffab99 · bffab99
1 parent 473c79e
commit bffab99
Showing 1 changed file with 9 additions and 7 deletions.
diff --git a/server/pkg/event/event.go b/server/pkg/event/event.go
@@ -7,10 +7,12 @@ import (
 	"sync"
 )
 
-var m sync.RWMutex
-var eventPool *ants.PoolWithFunc
-var handlers map[reflect.Type][]func(i interface{})
-var wg sync.WaitGroup
+var (
+	m         sync.RWMutex
+	eventPool *ants.PoolWithFunc
+	handlers  map[reflect.Type][]func(i interface{})
+	// wg        sync.WaitGroup
+)
 
 func init() {
 	var err error
@@ -28,16 +30,16 @@ func dispatch(i interface{}) {
 	}
 	for _, handler := range handlerList {
 		handler(i)
-		wg.Done()
+		// wg.Done()
 	}
 }
 
 func Send(e interface{}) {
 	if err := eventPool.Invoke(e); err != nil {
 		logrus.Error(err)
 	} else {
-		wg.Add(len(getHandlerList(e)))
-		wg.Wait()
+		// wg.Add(len(getHandlerList(e)))
+		// wg.Wait()
 	}
 }