apps/core
1
0
Fork 0
mirror of https://github.com/datarhei/core.git synced 2025-10-07 17:01:01 +08:00
Code Issues Packages Projects Releases Wiki Activity

Don't get always a new random string

Browse Source
This commit is contained in:
Ingo Oppermann
2024-03-15 11:51:10 +01:00
parent 76f79333c3
commit d14b0b9b13
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
io/fs/mem_test.go
View File

@@ -92,7 +92,7 @@ func BenchmarkMemReadFileWhileWriting(b *testing.B) {
mem, err := NewMemFilesystem(MemConfig{}) mem, err := NewMemFilesystem(MemConfig{})
require.NoError(b, err) require.NoError(b, err)
nReaders := 100 nReaders := 500
nWriters := 1000 nWriters := 1000
nFiles := 30 nFiles := 30
@@ -101,13 +101,15 @@ func BenchmarkMemReadFileWhileWriting(b *testing.B) {
writerWg := sync.WaitGroup{} writerWg := sync.WaitGroup{}
data := []byte(rand.StringAlphanumeric(2 * 1024))
for i := 0; i < nWriters; i++ { for i := 0; i < nWriters; i++ {
writerWg.Add(1) writerWg.Add(1)
go func(ctx context.Context, from int) { go func(ctx context.Context, from int) {
for i := 0; i < nFiles; i++ { for i := 0; i < nFiles; i++ {
path := fmt.Sprintf("/%d.dat", i+from) path := fmt.Sprintf("/%d.dat", i+from)
mem.WriteFile(path, []byte(rand.StringAlphanumeric(2*1024))) mem.WriteFile(path, data)
} }
ticker := time.NewTicker(40 * time.Millisecond) ticker := time.NewTicker(40 * time.Millisecond)
@@ -122,7 +124,7 @@ func BenchmarkMemReadFileWhileWriting(b *testing.B) {
case <-ticker.C: case <-ticker.C:
num := gorand.Intn(nFiles) + from num := gorand.Intn(nFiles) + from
path := fmt.Sprintf("/%d.dat", num) path := fmt.Sprintf("/%d.dat", num)
mem.WriteFile(path, []byte(rand.StringAlphanumeric(2*1024))) mem.WriteFile(path, data)
} }
} }
}(ctx, i*nFiles) }(ctx, i*nFiles)