mirror/ezbookkeeping
1
0
Fork 0
mirror of https://github.com/mayswind/ezbookkeeping.git synced 2026-05-20 17:54:30 +08:00
Code Issues Packages Projects Releases Wiki Activity

modify unit test case fail cause message

Browse Source
This commit is contained in:
MaysWind
2023-04-23 21:48:04 +08:00
parent c82d2abab4
commit 12d5837526
1 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/uuid/internal_generator_test.go
+10 -10
View File
@@ -86,7 +86,7 @@ func TestGenerateUuid_1000000TimesConcurrent(t *testing.T) {
var waitGroup sync.WaitGroup var waitGroup sync.WaitGroup
for routineIndex := 0; routineIndex < concurrentCount; routineIndex++ { for routineIndex := 0; routineIndex < concurrentCount; routineIndex++ {
go func() { go func(currentRoutineIndex int) {
waitGroup.Add(1) waitGroup.Add(1)
for cycle := 0; cycle < 40000; cycle++ { for cycle := 0; cycle < 40000; cycle++ {
@@ -105,18 +105,18 @@ func TestGenerateUuid_1000000TimesConcurrent(t *testing.T) {
} }
if uuidInfo.SequentialId == 0 { if uuidInfo.SequentialId == 0 {
if existedUnixTime, exists := generatedIds.Load(uuid); exists { if existedRoutineIndex, exists := generatedIds.Load(uuid); exists {
mutex.Lock() mutex.Lock()
assert.Fail(t, fmt.Sprintf("uuid \"%d\" conflicts, seq id is %d, existed unixtime is %d, current unix time is %d", uuid, uuidInfo.SequentialId, existedUnixTime, uuidInfo.UnixTime)) assert.Fail(t, fmt.Sprintf("uuid \"%d\" conflicts, unix time is %d, seq id is %d, existed routine index is %d, current routine index is %d", uuid, uuidInfo.UnixTime, uuidInfo.SequentialId, existedRoutineIndex, currentRoutineIndex))
mutex.Unlock() mutex.Unlock()
} }
generatedIds.Store(uuid, uuidInfo.UnixTime) generatedIds.Store(uuid, currentRoutineIndex)
} }
} }
waitGroup.Done() waitGroup.Done()
}() }(routineIndex)
} }
waitGroup.Wait() waitGroup.Wait()
@@ -208,7 +208,7 @@ func TestGenerateUuids_1000000TimesConcurrent(t *testing.T) {
var waitGroup sync.WaitGroup var waitGroup sync.WaitGroup
for routineIndex := 0; routineIndex < concurrentCount; routineIndex++ { for routineIndex := 0; routineIndex < concurrentCount; routineIndex++ {
go func() { go func(currentRoutineIndex int) {
waitGroup.Add(1) waitGroup.Add(1)
for cycle := 0; cycle < 400; cycle++ { for cycle := 0; cycle < 400; cycle++ {
@@ -228,18 +228,18 @@ func TestGenerateUuids_1000000TimesConcurrent(t *testing.T) {
mutex.Unlock() mutex.Unlock()
} }
if existedUnixTime, exists := generatedIds.Load(uuids[i]); exists { if existedRoutineIndex, exists := generatedIds.Load(uuids[i]); exists {
mutex.Lock() mutex.Lock()
assert.Fail(t, fmt.Sprintf("uuid \"%d\" conflicts, seq id is %d, existed unixtime is %d, current unix time is %d", uuids[i], uuidInfo.SequentialId, existedUnixTime, uuidInfo.UnixTime)) assert.Fail(t, fmt.Sprintf("uuid \"%d\" conflicts, unix time is %d, seq id is %d, existed routine index is %d, current routine index is %d", uuids[i], uuidInfo.UnixTime, uuidInfo.SequentialId, existedRoutineIndex, currentRoutineIndex))
mutex.Unlock() mutex.Unlock()
} }
generatedIds.Store(uuids[i], uuidInfo.UnixTime) generatedIds.Store(uuids[i], currentRoutineIndex)
} }
} }
waitGroup.Done() waitGroup.Done()
}() }(routineIndex)
} }
waitGroup.Wait() waitGroup.Wait()