diff --git a/kis/pool.go b/kis/pool.go
index 310ba80..cdd5658 100644
--- a/kis/pool.go
+++ b/kis/pool.go
@@ -213,6 +213,8 @@ func (pool *kisPool) CaaS(cname string, fname string, mode common.KisMode, c Caa
 
 // CallConnector 调度 Connector
 func (pool *kisPool) CallConnector(ctx context.Context, flow Flow, conn Connector, args interface{}) error {
+	pool.cLock.RLock() // 读锁
+	defer pool.cLock.RUnlock()
 	fn := flow.GetThisFunction()
 	fnConf := fn.GetConfig()
 	mode := common.KisMode(fnConf.FMode)