Skip to content

Commit

Permalink
fix: remove default case to allow goroutine to sleep
Browse files Browse the repository at this point in the history
  • Loading branch information
monrax committed Dec 14, 2023
1 parent c2bd166 commit 0442b15
Showing 1 changed file with 3 additions and 5 deletions.
8 changes: 3 additions & 5 deletions BaseLogger.go
Original file line number Diff line number Diff line change
Expand Up @@ -119,7 +119,7 @@ work:
func (logger *baseLogger) dispatcher() {
defer logger.wg.Done()
buffer := strings.Builder{}
created := time.Now()
autoFlush := time.NewTicker(time.Second)
logger.wg.Add(1)
go logger.worker()
dispatch:
Expand All @@ -133,7 +133,6 @@ dispatch:
buffer.WriteString(msg)
logger.submitQueue <- buffer
buffer = strings.Builder{}
created = time.Now()
}
}
case flush := <-logger.stop:
Expand All @@ -154,11 +153,10 @@ dispatch:
}
close(logger.submitQueue)
break dispatch
default:
if buffer.Len() != 0 && time.Since(created) > time.Second {
case <-autoFlush.C:
if buffer.Len() != 0 {
logger.submitQueue <- buffer
buffer = strings.Builder{}
created = time.Now()
}
}
}
Expand Down

0 comments on commit 0442b15

Please sign in to comment.