hashtable-latencies.go

package main

import (
	"sync"

	"github.com/valyala/fasthttp"
)

func main() {
	mutex := &sync.Mutex{}
	m := make(map[int][]byte)
	cnt := 0
	max := 250000
	pool := sync.Pool{
		New: func() interface{} {
			return make([]byte, 1024)
		},
	}

	handler := func(ctx *fasthttp.RequestCtx) {
		newBuffer := pool.Get().([]byte)
		for i := range newBuffer {
			newBuffer[i] = byte(i)
		}
		mutex.Lock()
		m[cnt] = newBuffer
		if cnt >= max {
			buf := m[cnt-max]
			delete(m, cnt-max)
			pool.Put(buf)
		}
		cnt++
		mutex.Unlock()

		ctx.WriteString("OK")
	}
	fasthttp.ListenAndServe(":8080", handler)
}