Method Push

queue/rw_queue.go:42–46

(event interface{})

}

func (this *RWQueue) Push(event interface{}) {
	this.write_lock.Lock()
	this.write_queue.push(event)
	this.write_lock.Unlock()
}

func (this *RWQueue) Get(event_list []interface{}, count uint32) (uint32, int) {
	this.read_lock.Lock()