fix: resolve race test

eventloop_unix.go

@@ -72,16 +72,9 @@ func (el *eventloop) loopRun(lockOSThread bool) {
 	defer func() {
 		el.closeAllConns()
 		el.ln.close()
-		if el.idx == 0 && el.svr.opts.Ticker {
-			close(el.svr.ticktock)
-		}
 		el.svr.signalShutdown()
 	}()
 
-	if el.idx == 0 && el.svr.opts.Ticker {
-		go el.loopTicker()
-	}
-
 	err := el.poller.Polling(el.handleEvent)
 	el.svr.logger.Infof("Event-loop(%d) is exiting due to error: %v", el.idx, err)
 }

reactor_bsd.go

@@ -34,16 +34,7 @@ func (svr *server) activateMainReactor(lockOSThread bool) {
 		defer runtime.UnlockOSThread()
 	}
 
-	defer func() {
-		if svr.opts.Ticker {
-			close(svr.ticktock)
-		}
-		svr.signalShutdown()
-	}()
-
-	if svr.opts.Ticker {
-		go svr.mainLoop.loopTicker()
-	}
+	defer svr.signalShutdown()
 
 	err := svr.mainLoop.poller.Polling(func(fd int, filter int16) error { return svr.acceptNewConnection(fd) })
 	svr.logger.Infof("Main reactor is exiting due to error: %v", err)

reactor_linux.go

@@ -32,16 +32,7 @@ func (svr *server) activateMainReactor(lockOSThread bool) {
 		defer runtime.UnlockOSThread()
 	}
 
-	defer func() {
-		if svr.opts.Ticker {
-			close(svr.ticktock)
-		}
-		svr.signalShutdown()
-	}()
-
-	if svr.opts.Ticker {
-		go svr.mainLoop.loopTicker()
-	}
+	defer svr.signalShutdown()
 
 	err := svr.mainLoop.poller.Polling(func(fd int, ev uint32) error { return svr.acceptNewConnection(fd) })
 	svr.logger.Infof("Main reactor is exiting due to error: %v", err)

server_unix.go

@@ -122,6 +122,11 @@ func (svr *server) activateEventLoops(numEventLoop int) (err error) {
 			el.calibrateCallback = svr.lb.calibrate
 			_ = el.poller.AddRead(el.ln.fd)
 			svr.lb.register(el)
+
+			// Start the ticker.
+			if el.idx == 0 && svr.opts.Ticker {
+				go el.loopTicker()
+			}
 		} else {
 			return
 		}
@@ -145,6 +150,11 @@ func (svr *server) activateReactors(numEventLoop int) error {
 			el.eventHandler = svr.eventHandler
 			el.calibrateCallback = svr.lb.calibrate
 			svr.lb.register(el)
+
+			// Start the ticker.
+			if el.idx == 0 && svr.opts.Ticker {
+				go el.loopTicker()
+			}
 		} else {
 			return err
 		}
@@ -159,7 +169,6 @@ func (svr *server) activateReactors(numEventLoop int) error {
 		el.idx = -1
 		el.svr = svr
 		el.poller = p
-		el.eventHandler = svr.eventHandler
 		_ = el.poller.AddRead(el.ln.fd)
 		svr.mainLoop = el
 
@@ -214,6 +223,11 @@ func (svr *server) stop(s Server) {
 		sniffErrorAndLog(svr.mainLoop.poller.Close())
 	}
 
+	// Stop the ticker.
+	if svr.opts.Ticker {
+		close(svr.ticktock)
+	}
+
 	atomic.StoreInt32(&svr.inShutdown, 1)
 }
 

server_windows.go

@@ -97,6 +97,8 @@ func (svr *server) startEventLoops(numEventLoop int) {
 		el.eventHandler = svr.eventHandler
 		el.calibrateCallback = svr.lb.calibrate
 		svr.lb.register(el)
+
+		// Start the ticker.
 		if el.idx == 0 && svr.opts.Ticker {
 			go el.loopTicker()
 		}
@@ -115,7 +117,6 @@ func (svr *server) stop(s Server) {
 
 	svr.eventHandler.OnShutdown(s)
 
-	close(svr.ticktock)
 	// Close listener.
 	svr.ln.close()
 	svr.listenerWG.Wait()
@@ -137,6 +138,11 @@ func (svr *server) stop(s Server) {
 	})
 	svr.loopWG.Wait()
 
+	// Stop the ticker.
+	if svr.opts.Ticker {
+		close(svr.ticktock)
+	}
+
 	atomic.StoreInt32(&svr.inShutdown, 1)
 }