Method doComplete

zasync_op/async_op_result.go:66–82

doComplete executes the completion callback function, double-checking when setting the processing result and callback function to prevent the possibility of not calling the callback function (执行完成回调,在设置处理结果和回调函数的时候双重检查，杜绝未调用回调函数的可能性)

()

// doComplete executes the completion callback function, double-checking when setting the processing result and callback function to prevent the possibility of not calling the callback function
// (执行完成回调,在设置处理结果和回调函数的时候双重检查，杜绝未调用回调函数的可能性)
func (aor *AsyncOpResult) doComplete() {
	v := aor.completeFunc.Load()
	if v == nil {
		return
	}

	cf := v.(func())

	// Prevent re-entry problems (防止可重入问题)
	if atomic.CompareAndSwapInt32(&aor.completeFuncHasAlreadyBeenCalled, 0, 1) {
		// Prevent cross-thread calling problems,
		// throw it to the corresponding business thread to execute
		// (防止跨线程调用问题,扔到所属业务线程里去执行)
		request := znet.NewFuncRequest(aor.conn, cf)
		aor.conn.GetMsgHandler().SendMsgToTaskQueue(request)
	}
}

// NewAsyncOpResult creates a new asynchronous result(新建异步结果)
func NewAsyncOpResult(conn ziface.IConnection) *AsyncOpResult {