Limit initial file loading

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

 type HashFileResult struct {
@ -265,6 +266,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)