Method Run

module/module.go:156–212

(wait *sync.WaitGroup)

}

func (this *module) Run(wait *sync.WaitGroup) {
	runtime.LockOSThread()
	defer this.recover(wait)
	wait.Add(1)
	defer wait.Done()
	this.begin_time = time.Now().UnixNano() / 1e9
	timer_manager := this.timer_manager
	var (
		event_msg  EventMsg = nil
		close_flag bool     = false
		ev_queue            = this.ev_queue
		event_chan          = ev_queue.SemaChan()
		timer_tick          = time.NewTimer(time.Duration(MODULE_TIMER_INTERVAL) * time.Millisecond)
		tick_c              = timer_tick.C
		nextWake            = 0
		event_list          = this.event_list
	)

	for {
		for {
			if this.event_index >= this.event_count {
				this.event_count = ev_queue.Get(event_list, uint32(MODULE_EVENT_LENGTH))
				this.event_index = 0
			}
			for this.event_index < this.event_count {
				event_msg = event_list[this.event_index].(EventMsg)
				event_list[this.event_index] = nil
				this.event_index++
				this.handle_event(event_msg)
				this.op_count++
			}
			nextWake = timer_manager.Execute(100)
			if this.event_count <= 0 && nextWake > 0 {
				break
			}
		}

		if ev_queue.WaitNotify() == false {
			continue
		}

		timer_tick.Reset(time.Duration(nextWake) * time.Millisecond)
		select {
		case close_flag = <-this.close_chan:
			if close_flag == true {
				goto run_close
			}
		case <-event_chan:
		case <-tick_c:
		}

		ev_queue.WaiterWake()
	}

run_close:
	this.do_close(wait)
}