package coroutine

import (
	"fmt"
	"gitee.com/quant1x/gox/concurrent"
	"gitee.com/quant1x/gox/timestamp"
	"strconv"
	"testing"
	"time"
)

var (
	rollingOnce RollingOnce
	cache1      = concurrent.NewHashMap[string, int]()
)

func lazyCacheInit() {
	for i := 0; i < 5; i++ {
		k := strconv.Itoa(i)
		//cache[k] = i
		cache1.Set(k, i)
		fmt.Println("reset", k, "=>", i)
	}
}

func cacheGetInt(key string) (int, bool) {
	rollingOnce.Do(lazyCacheInit)
	v, ok := cache1.Get(key)
	return v, ok
}

func cacheSetInt(key string, value int) {
	rollingOnce.Do(lazyCacheInit)
	cache1.Set(key, value)
}

func TestRollingOnce(t *testing.T) {
	var o1 RollingOnce
	o1.Do(func() {

	})
	o1.Close()
	rwCount := 1000
	producer := func() {
		for i := 0; i < rwCount; i++ {
			k := strconv.Itoa(i % 5)
			cacheSetInt(k, i)
			fmt.Println(k, "=>", i)
			time.Sleep(time.Millisecond * 10)
		}
	}
	reader := func() {
		for i := 0; i < rwCount; i++ {
			k := strconv.Itoa(i % 5)
			v, ok := cacheGetInt(k)
			fmt.Println(v, "<=", i, ":", ok)
			_ = v
			_ = ok
			time.Sleep(time.Millisecond * 10)
		}
	}

	go producer()
	go reader()
	count := 60
	for i := 0; i < count; i++ {
		//once.Reset()
		fmt.Println("--------------------")
		time.Sleep(time.Second)
	}
}

func Test_defaultTimeWindow(t *testing.T) {
	observer := getCurrentObserver(offsetWindow)
	fmt.Println(observer)
	a, b, c := nextTimeWindow(observer, rollingWindow)
	fmt.Println(a, b, c)
	nt := timestamp.Time(a)
	fmt.Println(nt.Format(time.DateTime))
}