Установлена переменная GOMAXPROCS

This commit is contained in:
Dmitry Sovetin
2020-04-28 11:19:30 +03:00
parent 6aee2882df
commit 70938eb6e6

12
main.go
View File

@@ -30,12 +30,18 @@ func lstn(connection *net.UDPConn, alarm chan struct{}) {
} }
func main() { func main() {
envFlag := runtime.GOMAXPROCS(runtime.NumCPU())
if envFlag > -1 {
fmt.Println("GOMAXPROCS =", runtime.NumCPU())
} else {
fmt.Println("GOMAXPROCS is default!")
}
argIP := flag.String("ip", "0.0.0.0", "Listen IP address") argIP := flag.String("ip", "0.0.0.0", "Listen IP address")
argPort := flag.Int("port", 10003, "Listen Port number") argPort := flag.Int("port", 10003, "Listen Port number")
flag.Parse() flag.Parse()
fmt.Println("IP Address: ", *argIP) fmt.Println("IP Address:", *argIP)
fmt.Println("Port Number: ", *argPort) fmt.Println("Port Number:", *argPort)
addr := net.UDPAddr{ addr := net.UDPAddr{
Port: *argPort, Port: *argPort,
@@ -46,7 +52,7 @@ func main() {
panic(err) panic(err)
} }
alarm := make(chan struct{}) alarm := make(chan struct{})
fmt.Println("CPU Threads: ", runtime.NumCPU()) fmt.Println("CPU Threads:", runtime.NumCPU())
for i := 0; i < runtime.NumCPU(); i++ { for i := 0; i < runtime.NumCPU(); i++ {
go lstn(connection, alarm) go lstn(connection, alarm)
} }