PID USER PR NI VIRT RES SHR S %CPU %MEM TIME+ COMMAND 489 chao

<a class="user-mention notranslate" data-hovercard-type="user" data-hovercard-url="/us

I had try change the parameters, but wasn't work. <div class="highlight highlight-

It's graceful, but how to optimize cpu usage? about goworker HOT 2 OPEN

chaos0108 commented on June 25, 2024

It's graceful, but how to optimize cpu usage?

from goworker.

Comments (2)

angus258963 commented on June 25, 2024 1

@chaos0108
Please use IntervalFloat instead of Interval, because it set Interval by IntervalFloat in Init().
And the unit of IntervalFloat is Second.

from goworker.

chaos0108 commented on June 25, 2024

I had try change the parameters, but wasn't work.

package main

import (
	"fmt"
	"github.com/benmanns/goworker"
	"log"
	"sso-api/config"
	"strconv"
)

//func myFunc(queue string, args ...interface{}) error {
//	log.Printf("From %s, %v\n", queue, args)
//	return nil
//}

func callbackUrl(queue string, args ...interface{}) error {
	log.Printf("From %s, %v\n", queue, args)
	return nil
}

func init() {
	_ = goworker.Init()
	settings := goworker.WorkerSettings{
		URI:            config.Goworker.GoworkerRedisUri,
		Connections:    50,
		Queues:         []string{config.Goworker.GoworkerQueueName},
		UseNumber:      true,
		ExitOnComplete: false,
		Concurrency:    2,
		Namespace:      config.Goworker.GoworkerNamespace,
		Interval:       1000000000,
	}
	goworker.SetSettings(settings)
	//goworker.Register("MyClass", myFunc)
	goworker.Register("Callback", callbackUrl)
}

func main() {
	if err := goworker.Work(); err != nil {
		fmt.Println("Error:", err)
	}
}