func main()

in benchmark/server/main.go [53:76]


func main() {
	flag.Parse()

	go func() {
		http.ListenAndServe(fmt.Sprintf(":%d", *pprofPort), nil)
	}()

	options := []getty.ServerOption{getty.WithLocalAddress(":8090")}

	if *taskPoolMode {
		taskPool = gxsync.NewTaskPoolSimple(*taskPoolSize)
		options = append(options, getty.WithServerTaskPool(taskPool))
	}

	server := getty.NewTCPServer(options...)

	go server.RunEventLoop(NewHelloServerSession)
	log.Printf("getty server start, listening at: 8090")

	signals := make(chan os.Signal, 1)
	signal.Notify(signals, os.Interrupt, syscall.SIGQUIT, syscall.SIGTERM, syscall.SIGINT)
	<-signals
	server.Close()
}