From da4f2f1810d21d6a89b1ae713cb3a17eea6e4131 Mon Sep 17 00:00:00 2001
From: Michael Li <alimy@gility.net>
Date: Sat, 9 Sep 2023 11:31:33 +0800
Subject: [PATCH] make event manager just do initial only once

---
 internal/events/events.go | 51 ++++++++++++++++++++++-----------------
 1 file changed, 29 insertions(+), 22 deletions(-)

diff --git a/internal/events/events.go b/internal/events/events.go
index 13bf75de..6c72bb4d 100644
--- a/internal/events/events.go
+++ b/internal/events/events.go
@@ -5,13 +5,18 @@
 package events
 
 import (
+	"sync"
+
 	"github.com/alimy/tryst/event"
 	"github.com/alimy/tryst/pool"
 	"github.com/rocboss/paopao-ce/internal/conf"
 	"github.com/sirupsen/logrus"
 )
 
-var _defaultEventManager event.EventManager
+var (
+	_defaultEventManager event.EventManager
+	_onceInitial         sync.Once
+)
 
 // OnEvent push event to gorotine pool then handled automatic.
 func OnEvent(event event.Event) {
@@ -19,27 +24,29 @@ func OnEvent(event event.Event) {
 }
 
 func Initial() {
-	var opts []pool.Option
-	s := conf.EventManagerSetting
-	if s.MinWorker > 5 {
-		opts = append(opts, pool.MinWorkerOpt(s.MinWorker))
-	} else {
-		opts = append(opts, pool.MinWorkerOpt(5))
-	}
-	if s.MaxEventBuf > 10 {
-		opts = append(opts, pool.MaxRequestBufOpt(s.MaxEventBuf))
-	} else {
-		opts = append(opts, pool.MaxRequestBufOpt(10))
-	}
-	if s.MaxTempEventBuf > 10 {
-		opts = append(opts, pool.MaxRequestTempBufOpt(s.MaxTempEventBuf))
-	} else {
-		opts = append(opts, pool.MaxRequestTempBufOpt(10))
-	}
-	opts = append(opts, pool.MaxTickCountOpt(s.MaxTickCount), pool.TickWaitTimeOpt(s.TickWaitTime))
-	_defaultEventManager = event.NewEventManager(func(req event.Event, err error) {
-		logrus.Errorf("handle event[%s] occurs error: %s", req.Name(), err)
-	}, opts...)
+	_onceInitial.Do(func() {
+		var opts []pool.Option
+		s := conf.EventManagerSetting
+		if s.MinWorker > 5 {
+			opts = append(opts, pool.MinWorkerOpt(s.MinWorker))
+		} else {
+			opts = append(opts, pool.MinWorkerOpt(5))
+		}
+		if s.MaxEventBuf > 10 {
+			opts = append(opts, pool.MaxRequestBufOpt(s.MaxEventBuf))
+		} else {
+			opts = append(opts, pool.MaxRequestBufOpt(10))
+		}
+		if s.MaxTempEventBuf > 10 {
+			opts = append(opts, pool.MaxRequestTempBufOpt(s.MaxTempEventBuf))
+		} else {
+			opts = append(opts, pool.MaxRequestTempBufOpt(10))
+		}
+		opts = append(opts, pool.MaxTickCountOpt(s.MaxTickCount), pool.TickWaitTimeOpt(s.TickWaitTime))
+		_defaultEventManager = event.NewEventManager(func(req event.Event, err error) {
+			logrus.Errorf("handle event[%s] occurs error: %s", req.Name(), err)
+		}, opts...)
+	})
 }
 
 func Restart() {