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)
- }
- })
- }
- }
|