支持Run方法

miraihttp.go

@@ -103,11 +103,7 @@ func Connect(host string, port int, channel WsChannel, verifyKey string, qq int6
 							}
 						}
 					}
-					if b.eventChan == nil {
-						go fun()
-					} else {
-						b.eventChan.Put(fun)
-					}
+					b.Run(fun)
 				}
 			} else {
 				b.handlerLock.RUnlock()
@@ -146,6 +142,15 @@ func (b *Bot) SetLimiter(limiterType string, l *rate.Limiter) {
 	b.limiter.Store(&limiter{limiterType: limiterType, limiter: l})
 }
 
+// Run 如果不是并发方式启动，则此方法会将函数放入事件队列。如果是并发方式启动，则此方法等同于go f()。
+func (b *Bot) Run(f func()) {
+	if b.eventChan == nil {
+		go f()
+	} else {
+		b.eventChan.Put(f)
+	}
+}
+
 // request 发送请求
 func (b *Bot) request(command, subCommand string, m any) (gjson.Result, error) {
 	limiter := b.limiter.Load()