localhots/shezmu
1
0
Fork 0
Code Releases Activity

Collect task wait statistics

Browse Source
This commit is contained in:
Gregory Eremin 2015-10-24 18:08:12 +03:00
parent bfa1575d79
commit 1550495bf9
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
satan.go
View File

@ -126,8 +126,11 @@ func (s *Satan) runWorker() {
defer log.Printf("Worker #%d has stopped", i) defer log.Printf("Worker #%d has stopped", i)
for { for {
start := time.Now()
select { select {
case t := <-s.queue: case t := <-s.queue:
dur := time.Now().UnixNano() - start.UnixNano()
s.Statistics.Add("TaskWait", time.Duration(dur))
s.processTask(t) s.processTask(t)
case <-s.shutdownWorkers: case <-s.shutdownWorkers:
return return