change log
This commit is contained in:
parent
cc94c074cc
commit
684d82f7bd
8
uid.go
8
uid.go
@ -100,8 +100,8 @@ func (idg *idCreator) backgroudTaskForGenerateRange() {
|
|||||||
|
|
||||||
// doing range generator
|
// doing range generator
|
||||||
for i := 0; ; i++ {
|
for i := 0; ; i++ {
|
||||||
|
logStr := ""
|
||||||
log.SetLogid(fmt.Sprintf("uidcreator%07d", i))
|
log.SetLogid(fmt.Sprintf("uidcreator%07d", i))
|
||||||
log.PrintPretty("backgroud info, ranges:", idg.Ranges)
|
|
||||||
for prefix, queue := range idg.Ranges {
|
for prefix, queue := range idg.Ranges {
|
||||||
var qlen = queue.Len()
|
var qlen = queue.Len()
|
||||||
var timeoutMs = 1 * time.Millisecond
|
var timeoutMs = 1 * time.Millisecond
|
||||||
@ -120,6 +120,12 @@ func (idg *idCreator) backgroudTaskForGenerateRange() {
|
|||||||
} else if int(timeoutMs) < 0 {
|
} else if int(timeoutMs) < 0 {
|
||||||
time.Sleep(-timeoutMs)
|
time.Sleep(-timeoutMs)
|
||||||
}
|
}
|
||||||
|
if i%50 == 0 {
|
||||||
|
logStr += fmt.Sprintf("queue-legth:(%s,%d);", prefix, queue.Len())
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if i%50 == 0 {
|
||||||
|
log.Infof("backgroud idcreator info: %s", logStr)
|
||||||
}
|
}
|
||||||
time.Sleep(3000 * time.Millisecond)
|
time.Sleep(3000 * time.Millisecond)
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user