Commit 28b295ee authored by Upliner's avatar Upliner

Reduce query delays

parent 11d09df2
...@@ -115,7 +115,6 @@ func main() { ...@@ -115,7 +115,6 @@ func main() {
go func() { go func() {
for _, item := range items { for _, item := range items {
fchan <- asyncItem{time.Now(),conn.SelectAsync("visitorid_matching", "primary", 0, 1, tarantool.IterEq, []interface{}{"host1", "host2", item})} fchan <- asyncItem{time.Now(),conn.SelectAsync("visitorid_matching", "primary", 0, 1, tarantool.IterEq, []interface{}{"host1", "host2", item})}
time.Sleep(time.Microsecond*50)
} }
close(fchan) close(fchan)
}() }()
...@@ -155,7 +154,7 @@ func main() { ...@@ -155,7 +154,7 @@ func main() {
tt += tm tt += tm
mu.Unlock() mu.Unlock()
}() }()
time.Sleep(time.Millisecond) time.Sleep(time.Microsecond * 100)
} }
fmt.Println("mixed max =", tmx*1000) fmt.Println("mixed max =", tmx*1000)
fmt.Println("mixed avg =", tt*1000/float64(len(items))) fmt.Println("mixed avg =", tt*1000/float64(len(items)))
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment