zhengchen.tao/ezbookkeeping
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix the problem that unit test would not run sometimes

Browse Source
This commit is contained in:
MaysWind
2023-08-28 23:06:03 +08:00
parent caa83c0432
commit 28903615ed
1 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/uuid/internal_generator_test.go
+8 -8
View File
@@ -101,9 +101,9 @@ func TestGenerateUuid_10000TimesConcurrent(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(currentRoutineIndex int) { waitGroup.Add(1)
waitGroup.Add(1)
go func(currentRoutineIndex int) {
for cycle := 0; cycle < 1000; cycle++ { for cycle := 0; cycle < 1000; cycle++ {
generationStartUnixTime := time.Now().Unix() generationStartUnixTime := time.Now().Unix()
uuid := generator.GenerateUuid(UUID_TYPE_USER) uuid := generator.GenerateUuid(UUID_TYPE_USER)
@@ -147,9 +147,9 @@ 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(currentRoutineIndex int) { waitGroup.Add(1)
waitGroup.Add(1)
go func(currentRoutineIndex int) {
for cycle := 0; cycle < 100000; cycle++ { for cycle := 0; cycle < 100000; cycle++ {
if cycle%50000 == 0 { // each server can only generate 500,000 (10 * 50000) uuids in one second if cycle%50000 == 0 { // each server can only generate 500,000 (10 * 50000) uuids in one second
time.Sleep(1000 * time.Millisecond) time.Sleep(1000 * time.Millisecond)
@@ -282,9 +282,9 @@ func TestGenerateUuids_20000TimesConcurrent(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(currentRoutineIndex int) { waitGroup.Add(1)
waitGroup.Add(1)
go func(currentRoutineIndex int) {
for cycle := 0; cycle < 100; cycle++ { for cycle := 0; cycle < 100; cycle++ {
generationStartUnixTime := time.Now().Unix() generationStartUnixTime := time.Now().Unix()
uuids := generator.GenerateUuids(UUID_TYPE_USER, expectedUuidCount) uuids := generator.GenerateUuids(UUID_TYPE_USER, expectedUuidCount)
@@ -331,9 +331,9 @@ 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(currentRoutineIndex int) { waitGroup.Add(1)
waitGroup.Add(1)
go func(currentRoutineIndex int) {
for cycle := 0; cycle < 400; cycle++ { for cycle := 0; cycle < 400; cycle++ {
if cycle%200 == 0 { // each server can only generate 500,000 (10 * 250 * 200) uuids in one second if cycle%200 == 0 { // each server can only generate 500,000 (10 * 250 * 200) uuids in one second
time.Sleep(1000 * time.Millisecond) time.Sleep(1000 * time.Millisecond)