QueueCalc.go

package main

import "fmt"

type ThreadConfig struct {
	MaxThreads   int
	CorePoolSize int
	Consumers    int
	TxSize       int
	QueueSize    int
}

func NewThreadConfig() *ThreadConfig {
	return &ThreadConfig{
		MaxThreads:   8,
		CorePoolSize: 1,
		Consumers:    1,
		TxSize:       1,
	}
}

func NormalizeConfig(config *ThreadConfig) {

	totalItems := config.TxSize * config.Consumers

	queueSize := 0

	if totalItems > config.MaxThreads {
		queueSize = config.TxSize * config.Consumers
	}

	config.QueueSize = queueSize
}

func main() {

	config := NewThreadConfig()
	config.TxSize = 20
	config.Consumers = 2
	NormalizeConfig(config)

	fmt.Println("Hello, world ", config.QueueSize)
}