Ma/origin
1
0
Fork 0
mirror of https://github.com/duanhf2012/origin.git synced 2026-02-03 22:45:13 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

优化concurrent与rpc模块

Browse Source
This commit is contained in:
duanhf2012
2023-05-04 14:21:29 +08:00
parent ddeaaf7d77
commit 5675681ab1
2 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
concurrent/dispatch.go
View File

@@ -80,7 +80,7 @@ func (d *dispatch) run() {
} }
func (d *dispatch) processTimer() { func (d *dispatch) processTimer() {
if d.idle == true && d.workerNum > d.minConcurrentNum { if d.idle == true && d.workerNum > atomic.LoadInt32(&d.minConcurrentNum) {
d.processIdle() d.processIdle()
} }

6
rpc/rpchandler.go
View File

@@ -291,14 +291,16 @@ func (handler *RpcHandler) HandlerRpcRequest(request *RpcRequest) {
request.requestHandle(nil, RpcError(rErr)) request.requestHandle(nil, RpcError(rErr))
return return
} }
requestHanle := request.requestHandle
returnValues := v.method.Func.Call(paramList) returnValues := v.method.Func.Call(paramList)
errInter := returnValues[0].Interface() errInter := returnValues[0].Interface()
if errInter != nil { if errInter != nil {
err = errInter.(error) err = errInter.(error)
} }
if request.requestHandle != nil && v.hasResponder == false { if v.hasResponder == false && requestHanle != nil {
request.requestHandle(oParam.Interface(), ConvertError(err)) requestHanle(oParam.Interface(), ConvertError(err))
} }
} }