feature: invoke function in main logic goroutine

handler.go

@@ -36,6 +36,7 @@ import (
 
 // Unhandled message buffer size
 const packetBacklog = 1024
+const funcBacklog = 1 << 8
 
 var (
 	// handler service singleton
@@ -72,6 +73,7 @@ type (
 		handlers       map[string]*component.Handler // all handler method
 		chLocalProcess chan unhandledMessage         // packets that process locally
 		chCloseSession chan *session.Session         // closed session
+		chFunction     chan func()                   // function that called in logic gorontine
 	}
 
 	unhandledMessage struct {
@@ -88,6 +90,7 @@ func newHandlerService() *handlerService {
 		handlers:       make(map[string]*component.Handler),
 		chLocalProcess: make(chan unhandledMessage, packetBacklog),
 		chCloseSession: make(chan *session.Session, packetBacklog),
+		chFunction:     make(chan func(), funcBacklog),
 	}
 
 	return h
@@ -109,6 +112,18 @@ func pcall(method reflect.Method, args []reflect.Value) {
 	}
 }
 
+// call handler with protected
+func pinvoke(fn func()) {
+	defer func() {
+		if err := recover(); err != nil {
+			logger.Println(fmt.Sprintf("nano/invoke: %v", err))
+			println(stack())
+		}
+	}()
+
+	fn()
+}
+
 func onSessionClosed(s *session.Session) {
 	defer func() {
 		if err := recover(); err != nil {
@@ -148,6 +163,9 @@ func (h *handlerService) dispatch() {
 		case s := <-h.chCloseSession: // session closed callback
 			onSessionClosed(s)
 
+		case fn := <-h.chFunction:
+			pinvoke(fn)
+
 		case <-globalTicker.C: // execute cron task
 			cron()
 

invoke.go

@@ -0,0 +1,6 @@
+package nano
+
+// Invoke invokes function in main logic goroutine
+func Invoke(fn func()) {
+	handler.chFunction <- fn
+}

timer.go

@@ -14,7 +14,7 @@ const (
 
 var (
 	// default timer backlog
-	timerBacklog = 128
+	timerBacklog = 1 << 8
 
 	// timerManager manager for all timers
 	timerManager = &struct {