test/gf
1
0
Fork 0
mirror of https://gitee.com/johng/gf.git synced 2024-12-01 03:38:35 +08:00
Code Issues Actions 15 Packages Projects Releases Wiki Activity

Improve gmutex unit testing.

Browse Source
This commit is contained in:
hailaz 2019-06-24 12:50:00 +08:00
parent 1434800982
commit 2b02f7e210
1 changed files with 32 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

50
g/os/gmutex/gmutex_uinit_test.go
View File

@ -38,6 +38,24 @@ func Test_Mutex_RUnlock(t *testing.T) {
gtest.Assert(mu.IsRLocked(), false)
})
//RLock before Lock
gtest.Case(t, func() {
mu := gmutex.New()
mu.RLock()
go func() {
mu.Lock()
time.Sleep(300 * time.Millisecond)
mu.Unlock()
}()
time.Sleep(100 * time.Millisecond)
mu.RUnlock()
gtest.Assert(mu.IsRLocked(), false)
time.Sleep(100 * time.Millisecond)
gtest.Assert(mu.IsLocked(), true)
time.Sleep(400 * time.Millisecond)
gtest.Assert(mu.IsLocked(), false)
})
}
func Test_Mutex_IsLocked(t *testing.T) {
@ -227,32 +245,28 @@ func Test_Mutex_TryRLockFunc(t *testing.T) {
go func() {
mu.LockFunc(func() {
array.Append(1)
time.Sleep(500 * time.Millisecond)
time.Sleep(200 * time.Millisecond)
})
}()
go func() {
time.Sleep(200 * time.Millisecond)
mu.TryRLockFunc(func() {
array.Append(1)
})
}()
go func() {
time.Sleep(700 * time.Millisecond)
mu.TryRLockFunc(func() {
array.Append(1)
})
}()
go func() {
time.Sleep(700 * time.Millisecond)
time.Sleep(100 * time.Millisecond)
mu.TryRLockFunc(func() {
array.Append(1)
})
}()
for index := 0; index < 1000; index++ {
go func() {
time.Sleep(300 * time.Millisecond)
mu.TryRLockFunc(func() {
array.Append(1)
})
}()
}
time.Sleep(10 * time.Millisecond)
gtest.Assert(array.Len(), 1)
time.Sleep(100 * time.Millisecond)
gtest.Assert(array.Len(), 1)
time.Sleep(500 * time.Millisecond)
gtest.Assert(array.Len(), 1)
time.Sleep(500 * time.Millisecond)
gtest.Assert(array.Len(), 3)
time.Sleep(600 * time.Millisecond)
gtest.Assert(array.Len(), 1001)
})
}