HI, is it to delete element in iterator?

[roooneychina]

HI, would you like kindly to tell me about that :is it to delete element in iterator? many thanks.

[roooneychina]

it seems that it is statisfied me. great func TestIterator(t *testing.T) { cache := NewCache(1024) count := 5 for i := 0; i < count; i++ { err := cache.Set([]byte(fmt.Sprintf("%d", i)), []byte(fmt.Sprintf("val%d", i)), 0) if err != nil { t.Error(err) } } //fmt.Println(cache.EntryCount()) go func() { res, err33 := cache.Get([]byte(fmt.Sprintf("%d", 3))) if err33 != nil{ t.Error((err33)) } fmt.Println(string(res)) cache.Del([]byte(fmt.Sprintf("%d", 3))) fmt.Println(cache.EntryCount()) cache.Del([]byte(fmt.Sprintf("%d", 2))) cache.Del([]byte(fmt.Sprintf("%d", 0))) cache.Del([]byte(fmt.Sprintf("%d", 1))) cache.Del([]byte(fmt.Sprintf("%d", 1))) }()

go func() {
	time.Sleep(time.Second*10)

	err := cache.Set([]byte(fmt.Sprintf("%d", 6)), []byte(fmt.Sprintf("val%d", 6)), 0)
	if err!= nil{
		t.Error((err))
	}
//	fmt.Println(string(res))
	//cache.Del([]byte(fmt.Sprintf("%d", 3)))
	fmt.Println(cache.EntryCount())
}()
// Set some value that expires to make sure expired entry is not returned.
//cache.Set([]byte("abc"), []byte("def"), 1)
//time.Sleep(5 * time.Second)
it := cache.NewIterator()
var ii int64
for ii=0; ii < cache.EntryCount(); ii++ {
	entry := it.Next()
	time.Sleep(time.Second*5)
	if entry == nil {
		continue;
		//t.Fatalf("entry is nil for %d", i)
	}
	go func() {
		_, err33 := cache.Get([]byte(fmt.Sprintf("%d", 2)))
		if err33 != nil{
			fmt.Println("not found")
		}

	}()

	fmt.Println("start")
	fmt.Println(string(entry.Value))
	if string(entry.Value) != "val"+string(entry.Key) {
		t.Fatalf("entry key value not match %s %s", entry.Key, entry.Value)
	}
	err := cache.Set([]byte(fmt.Sprintf("%d", 4)), []byte(fmt.Sprintf("val%d", 18)), 0)
	if err!= nil{
		t.Error((err))
	}
	cache.Del([]byte(fmt.Sprintf("%d", 4)))
	cache.Del([]byte(fmt.Sprintf("%d", 4)))

}
e := it.Next()
if e != nil {
	t.Fail()
}
time.Sleep(time.Second*20)
fmt.Println("second round")
it2 := cache.NewIterator()
var i int64
for i = 0; i < cache.EntryCount(); i++ {
	entry := it2.Next()

	if entry == nil {
		break
	}
	fmt.Println(string(entry.Value))
}

}