[Bug]: example gnet for echo tcp uses too much memory about gnet HOT 7 CLOSED

package main

import (
        "flag"
        "fmt"
        "log"
        "net/http"
        _ "net/http/pprof"

        "github.com/panjf2000/gnet/v2"
)

type echoServer struct {
        gnet.BuiltinEventEngine

        eng       gnet.Engine
        addr      string
        multicore bool
}

func (es *echoServer) OnBoot(eng gnet.Engine) gnet.Action {
        es.eng = eng
        log.Printf("echo server with multi-core=%t is listening on %s\n", es.multicore, es.addr)
        return gnet.None
}

func (es *echoServer) OnTraffic(c gnet.Conn) gnet.Action {
        buf, _ := c.Next(-1)
        c.Write(buf)
        return gnet.None
}

func main() {
        var port int
        var multicore bool
        var pprofPort int

        // Example command: go run main.go --port 9000 --multicore=true --pprofPort=6060
        flag.IntVar(&port, "port", 9000, "Set the port for the TCP server")
        flag.BoolVar(&multicore, "multicore", false, "Enable multicore processing")
        flag.IntVar(&pprofPort, "pprofPort", 6060, "Set the port for the pprof HTTP server")
        flag.Parse()

        // Start pprof server
        go func() {
                log.Printf("Starting pprof server on http://localhost:%d/debug/pprof/\n", pprofPort)
                log.Println(http.ListenAndServe(fmt.Sprintf("localhost:%d", pprofPort), nil))
        }()

        // Setup and start TCP echo server
        echo := &echoServer{addr: fmt.Sprintf("tcp://:%d", port), multicore: multicore}
        log.Fatal(gnet.Run(echo, echo.addr, gnet.WithMulticore(multicore)))
}

iperf -c 127.0.0.1 -p 8080 -t 3600

package main

import (
        "flag"
        "fmt"
        "log"
        "net/http"
        _ "net/http/pprof"

        "github.com/panjf2000/gnet/v2"
)

type echoServer struct {
        gnet.BuiltinEventEngine

        eng       gnet.Engine
        addr      string
        multicore bool
}

func (es *echoServer) OnBoot(eng gnet.Engine) gnet.Action {
        es.eng = eng
        log.Printf("echo server with multi-core=%t is listening on %s\n", es.multicore, es.addr)
        return gnet.None
}

func (es *echoServer) OnTraffic(c gnet.Conn) gnet.Action {
        buf, _ := c.Next(-1)
        c.Write(buf)
        return gnet.None
}

func main() {
        var port int
        var multicore bool
        var pprofPort int

        // Example command: go run main.go --port 9000 --multicore=true --pprofPort=6060
        flag.IntVar(&port, "port", 9000, "Set the port for the TCP server")
        flag.BoolVar(&multicore, "multicore", false, "Enable multicore processing")
        flag.IntVar(&pprofPort, "pprofPort", 6060, "Set the port for the pprof HTTP server")
        flag.Parse()

        // Start pprof server
        go func() {
                log.Printf("Starting pprof server on http://localhost:%d/debug/pprof/\n", pprofPort)
                log.Println(http.ListenAndServe(fmt.Sprintf("localhost:%d", pprofPort), nil))
        }()

        // Setup and start TCP echo server
        echo := &echoServer{addr: fmt.Sprintf("tcp://:%d", port), multicore: multicore}
        log.Fatal(gnet.Run(echo, echo.addr, gnet.WithMulticore(multicore), gnet.WithEdgeTriggeredIO(true)))
}