localhots/shezmu
1
0
Fork 0
Code Releases Activity

Collecting task wait time for workers is no longer necessary

Browse Source
This commit is contained in:
Gregory Eremin 2015-10-27 04:00:41 +03:00
parent 7432c5e0d8
commit 3033508706
1 changed files with 0 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
satan.go
View File

@ -108,7 +108,6 @@ func (s *Satan) StopDaemons() {
close(s.queue) close(s.queue)
fmt.Println(s.runtimeStats.Fetch(stats.Latency)) fmt.Println(s.runtimeStats.Fetch(stats.Latency))
fmt.Println(s.runtimeStats.Fetch(stats.TaskWait))
} }
func (s *Satan) runWorker() { func (s *Satan) runWorker() {
@ -123,11 +122,8 @@ func (s *Satan) runWorker() {
}() }()
for { for {
start := time.Now()
select { select {
case t := <-s.queue: case t := <-s.queue:
dur := time.Now().UnixNano() - start.UnixNano()
s.runtimeStats.Add(stats.TaskWait, time.Duration(dur))
s.processTask(t) s.processTask(t)
case <-s.shutdownWorkers: case <-s.shutdownWorkers:
return return