From 3315e6027227127e2ed6efa2290d4d76e4071106 Mon Sep 17 00:00:00 2001 From: Kevin Wan Date: Wed, 26 Feb 2025 19:19:24 +0800 Subject: [PATCH] chore: performance tunning for stable runner (#4670) --- core/threading/stablerunner.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/core/threading/stablerunner.go b/core/threading/stablerunner.go index 0449dae89..ae715e4ab 100644 --- a/core/threading/stablerunner.go +++ b/core/threading/stablerunner.go @@ -5,6 +5,7 @@ import ( "runtime" "sync" "sync/atomic" + "time" ) const factor = 10 @@ -100,6 +101,6 @@ func (r *StableRunner[I, O]) Wait() { close(r.done) r.runner.Wait() for atomic.LoadUint64(&r.consumedIndex) < atomic.LoadUint64(&r.writtenIndex) { - runtime.Gosched() + time.Sleep(time.Millisecond) } }