From 70b58138b92a5015469608ebf16768808859e67a Mon Sep 17 00:00:00 2001 From: Daniel <dhaavi@users.noreply.github.com> Date: Fri, 4 Nov 2022 16:11:38 +0100 Subject: [PATCH] Set default microtask threshold in init for easier override --- modules/microtasks.go | 3 ++- modules/start.go | 2 -- 2 files changed, 2 insertions(+), 3 deletions(-) diff --git a/modules/microtasks.go b/modules/microtasks.go index 5fa8d72..2916685 100644 --- a/modules/microtasks.go +++ b/modules/microtasks.go @@ -30,7 +30,8 @@ const ( func init() { var microTasksVal int32 microTasks = µTasksVal - var microTasksThreshholdVal int32 + + microTasksThreshholdVal := int32(runtime.GOMAXPROCS(0) * 2) microTasksThreshhold = µTasksThreshholdVal } diff --git a/modules/start.go b/modules/start.go index c5ab4ab..d73da5e 100644 --- a/modules/start.go +++ b/modules/start.go @@ -4,7 +4,6 @@ import ( "errors" "fmt" "os" - "runtime" "github.com/tevino/abool" @@ -36,7 +35,6 @@ func Start() error { defer mgmtLock.Unlock() // start microtask scheduler - SetMaxConcurrentMicroTasks(runtime.GOMAXPROCS(0)) go microTaskScheduler() // inter-link modules