Limit initial file loading

2022-08-04 18:11:53 +02:00 · 2022-08-04 18:11:53 +02:00 · 5989ce159c
parent 80f91c85f1
commit 5989ce159c
1 changed files with 6 additions and 0 deletions
--- a/SynchRoGazer.go
+++ b/SynchRoGazer.go
@ -19,6 +19,7 @@ import (
 	"os"
 	"runtime"
 	"sync/atomic"
+	"time"
 )

 type HashFileResult struct {
@ -287,6 +288,11 @@ func main() {
 			path := scanner.Text()
 			atomic.AddInt64(&entries, 1)

+			for atomic.LoadInt64(&taskCount) >= (int64(*taskLimit) + 1) {
+				runtime.Gosched()
+				time.Sleep(time.Millisecond * 20)
+			}
+
 			atomic.AddInt64(&taskCount, 1)
 			go func() {
 				defer atomic.AddInt64(&taskCount, -1)