|
@@ -110,7 +110,7 @@ func (executor *UnboundedExecutor) checkGoroutines() bool {
|
|
|
defer executor.activeGoroutinesMutex.Unlock()
|
|
defer executor.activeGoroutinesMutex.Unlock()
|
|
|
for startFrom, count := range executor.activeGoroutines {
|
|
for startFrom, count := range executor.activeGoroutines {
|
|
|
if count > 0 {
|
|
if count > 0 {
|
|
|
- InfoLogger.Println("event!unbounded_executor.still waiting goroutines to quit",
|
|
|
|
|
|
|
+ InfoLogger.Println("UnboundedExecutor is still waiting goroutines to quit",
|
|
|
"startFrom", startFrom,
|
|
"startFrom", startFrom,
|
|
|
"count", count)
|
|
"count", count)
|
|
|
return false
|
|
return false
|
Tao Wen