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