| 12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970 | 
							- package cache
 
- import (
 
- 	"sync"
 
- 	"testing"
 
- 	"time"
 
- )
 
- func TestMemory_Get(t *testing.T) {
 
- 	type fields struct {
 
- 		items   *sync.Map
 
- 		queue   *sync.Map
 
- 		wait    sync.WaitGroup
 
- 		mutex   sync.RWMutex
 
- 		PoolNum uint
 
- 	}
 
- 	type args struct {
 
- 		key    string
 
- 		value  string
 
- 		expire int
 
- 	}
 
- 	tests := []struct {
 
- 		name    string
 
- 		fields  fields
 
- 		args    args
 
- 		want    string
 
- 		wantErr bool
 
- 	}{
 
- 		{
 
- 			"test01",
 
- 			fields{},
 
- 			args{
 
- 				key:    "test",
 
- 				value:  "test",
 
- 				expire: 10,
 
- 			},
 
- 			"test",
 
- 			false,
 
- 		},
 
- 		{
 
- 			"test02",
 
- 			fields{},
 
- 			args{
 
- 				key:    "test",
 
- 				value:  "test1",
 
- 				expire: 1,
 
- 			},
 
- 			"",
 
- 			true,
 
- 		},
 
- 	}
 
- 	for _, tt := range tests {
 
- 		t.Run(tt.name, func(t *testing.T) {
 
- 			m := NewMemory()
 
- 			if err := m.Set(tt.args.key, tt.args.value, tt.args.expire); err != nil {
 
- 				t.Errorf("Set() error = %v", err)
 
- 				return
 
- 			}
 
- 			time.Sleep(2 * time.Second)
 
- 			got, err := m.Get(tt.args.key)
 
- 			if (err != nil) != tt.wantErr {
 
- 				t.Errorf("Get() error = %v, wantErr %v", err, tt.wantErr)
 
- 				return
 
- 			}
 
- 			if got != tt.want {
 
- 				t.Errorf("Get() got = %v, want %v", got, tt.want)
 
- 			}
 
- 		})
 
- 	}
 
- }
 
 
  |