Set default microtask threshold in init for easier override

safing · Nov 4, 2022 · 70b5813 · 70b5813
1 parent d21c8e6
commit 70b5813
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/modules/microtasks.go b/modules/microtasks.go
@@ -30,7 +30,8 @@ const (
 func init() {
 	var microTasksVal int32
 	microTasks = &microTasksVal
-	var microTasksThreshholdVal int32
+
+	microTasksThreshholdVal := int32(runtime.GOMAXPROCS(0) * 2)
 	microTasksThreshhold = &microTasksThreshholdVal
 }
 

diff --git 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