package main

import (
	"fmt"
	"gitee.com/liujinsuo/tool/toolcache"
	"sync"
	"time"
)

func main() {
	fn2()
}

func fn2() {
	wg := &sync.WaitGroup{}
	cache := toolcache.NewMemCache[string]()
	wg.Add(2)

	f := func() (string, error) {
		time.Sleep(time.Second)
		return "111", nil
	}

	go func() {
		defer wg.Done()
		for i := 0; i < 10; i++ {
			fetch, err, shared := cache.Fetch("1111", time.Minute, f)
			fmt.Println("aaaa", fetch, err, shared)
		}
	}()
	go func() {
		defer wg.Done()
		for i := 0; i < 10; i++ {
			fetch, err, shared := cache.Fetch("1111", time.Minute, f)
			fmt.Println("bbbb", fetch, err, shared)
		}
	}()
	wg.Wait()
}

func fn1() {
	cache := toolcache.NewMemCache[string]()
	cache.Set("111", "222", time.Second*5)
	cache.Set("112", "222", time.Second*5)
	cache.Set("113", "222", time.Second*5)
	cache.Set("114", "222", time.Second*5)
	cache.Set("115", "222", time.Second*5)
	cache.Set("116", "222", time.Second*5)

	{
		del, loaded := cache.LoadAndDelete("111")
		fmt.Println("删除后的结果", del, loaded)

		content, ok := cache.Get("111")
		fmt.Println("获取111", content, ok)

		del2, loaded2 := cache.LoadAndDelete("111")
		fmt.Println("删除后的结果", del2, loaded2)
	}

	time.Sleep(time.Second * 1000)
	for i := 0; i < 300; i++ {
		time.Sleep(time.Millisecond * 200)
		content, ok := cache.Get("111")
		if ok == false {
			fmt.Println(time.Now(), "--------false")
		} else {
			fmt.Println(time.Now(), content)
		}
	}

}