diff --git a/internal/service/polling/concurrency_service.go b/internal/service/polling/concurrency_service.go index 45c4ef2..83037ab 100644 --- a/internal/service/polling/concurrency_service.go +++ b/internal/service/polling/concurrency_service.go @@ -2,6 +2,7 @@ package polling import ( "context" + "math" "strings" "time" @@ -79,7 +80,7 @@ func (s *ConcurrencyService) List(ctx context.Context) ([]*ConcurrencyStatus, er status.Available = 0 } if cfg.MaxConcurrency > 0 { - status.Utilization = float64(current) / float64(cfg.MaxConcurrency) * 100 + status.Utilization = math.Round(float64(current)/float64(cfg.MaxConcurrency)*1000000) / 100 } result = append(result, status) @@ -117,7 +118,7 @@ func (s *ConcurrencyService) GetByTaskType(ctx context.Context, taskType string) status.Available = 0 } if cfg.MaxConcurrency > 0 { - status.Utilization = float64(current) / float64(cfg.MaxConcurrency) * 100 + status.Utilization = math.Round(float64(current)/float64(cfg.MaxConcurrency)*1000000) / 100 } return status, nil