异步队列新增Get方式

cluster/cluster.go

@@ -209,7 +209,6 @@ func (slf *CCluster) Start() error {
 	return nil
 }
 
-//Node.servicename.methodname
 //servicename.methodname
 //_servicename.methodname
 func (slf *CCluster) Call(NodeServiceMethod string, args interface{}, reply interface{}) error {

util/sync_queue.go

@@ -94,3 +94,9 @@ func (q *SyncQueue) IsClose() (v bool) {
 	q.lock.Unlock()
 	return
 }
+
+func (q *SyncQueue) Get(i int) interface{} {
+	q.lock.Lock()
+	defer q.lock.Unlock()
+	return q.buffer.Get(i)
+}