diff --git a/example/prependETA/main.go b/example/prependETA/main.go index f8dd01a..5ed8b54 100644 --- a/example/prependETA/main.go +++ b/example/prependETA/main.go @@ -29,7 +29,7 @@ defer wg.Done() blockSize := rand.Intn(maxBlockSize) + 1 for i := 0; i < 50; i++ { - time.Sleep(time.Duration(blockSize) * (50*time.Millisecond + time.Duration(rand.Intn(5*int(time.Millisecond))))) + sleep(blockSize) bar1.Incr(1) blockSize = rand.Intn(maxBlockSize) + 1 } @@ -44,7 +44,7 @@ defer wg.Done() blockSize := rand.Intn(maxBlockSize) + 1 for i := 0; i < 100; i++ { - time.Sleep(time.Duration(blockSize) * (50*time.Millisecond + time.Duration(rand.Intn(5*int(time.Millisecond))))) + sleep(blockSize) bar2.Incr(1) blockSize = rand.Intn(maxBlockSize) + 1 } @@ -59,7 +59,7 @@ defer wg.Done() blockSize := rand.Intn(maxBlockSize) + 1 for i := 0; i < 80; i++ { - time.Sleep(time.Duration(blockSize) * (50*time.Millisecond + time.Duration(rand.Intn(5*int(time.Millisecond))))) + sleep(blockSize) bar3.Incr(1) blockSize = rand.Intn(maxBlockSize) + 1 } @@ -70,3 +70,7 @@ // p.AddBar(1) // panic: you cannot reuse p, create new one! fmt.Println("stop") } + +func sleep(blockSize int) { + time.Sleep(time.Duration(blockSize) * (50*time.Millisecond + time.Duration(rand.Intn(5*int(time.Millisecond))))) +} diff --git a/example/prependElapsed/main.go b/example/prependElapsed/main.go index bc7ee9a..dd95447 100644 --- a/example/prependElapsed/main.go +++ b/example/prependElapsed/main.go @@ -28,7 +28,7 @@ defer wg.Done() blockSize := rand.Intn(maxBlockSize) + 1 for i := 0; i < 50; i++ { - time.Sleep(time.Duration(blockSize) * (50*time.Millisecond + time.Duration(rand.Intn(5*int(time.Millisecond))))) + sleep(blockSize) bar1.Incr(1) blockSize = rand.Intn(maxBlockSize) + 1 } @@ -42,7 +42,7 @@ defer wg.Done() blockSize := rand.Intn(maxBlockSize) + 1 for i := 0; i < 100; i++ { - time.Sleep(time.Duration(blockSize) * (50*time.Millisecond + time.Duration(rand.Intn(5*int(time.Millisecond))))) + sleep(blockSize) bar2.Incr(1) blockSize = rand.Intn(maxBlockSize) + 1 } @@ -56,7 +56,7 @@ defer wg.Done() blockSize := rand.Intn(maxBlockSize) + 1 for i := 0; i < 80; i++ { - time.Sleep(time.Duration(blockSize) * (50*time.Millisecond + time.Duration(rand.Intn(5*int(time.Millisecond))))) + sleep(blockSize) bar3.Incr(1) blockSize = rand.Intn(maxBlockSize) + 1 } @@ -67,3 +67,7 @@ // p.AddBar(1) // panic: you cannot reuse p, create new one! fmt.Println("stop") } + +func sleep(blockSize int) { + time.Sleep(time.Duration(blockSize) * (50*time.Millisecond + time.Duration(rand.Intn(5*int(time.Millisecond))))) +} diff --git a/example/remove/main.go b/example/remove/main.go index d47b750..86f3469 100644 --- a/example/remove/main.go +++ b/example/remove/main.go @@ -28,7 +28,7 @@ defer wg.Done() blockSize := rand.Intn(maxBlockSize) + 1 for i := 0; i < 50; i++ { - time.Sleep(time.Duration(blockSize) * (50*time.Millisecond + time.Duration(rand.Intn(5*int(time.Millisecond))))) + sleep(blockSize) bar1.Incr(1) blockSize = rand.Intn(maxBlockSize) + 1 } @@ -42,7 +42,7 @@ defer wg.Done() blockSize := rand.Intn(maxBlockSize) + 1 for i := 0; i < 100; i++ { - time.Sleep(time.Duration(blockSize) * (50*time.Millisecond + time.Duration(rand.Intn(5*int(time.Millisecond))))) + sleep(blockSize) bar2.Incr(1) if bar2.Current() > 42 && p.RemoveBar(bar2) { break @@ -59,7 +59,7 @@ defer wg.Done() blockSize := rand.Intn(maxBlockSize) + 1 for i := 0; i < 80; i++ { - time.Sleep(time.Duration(blockSize) * (50*time.Millisecond + time.Duration(rand.Intn(5*int(time.Millisecond))))) + sleep(blockSize) bar3.Incr(1) blockSize = rand.Intn(maxBlockSize) + 1 } @@ -70,3 +70,7 @@ // p.AddBar(2) // panic: you cannot reuse p, create new one! fmt.Println("stop") } + +func sleep(blockSize int) { + time.Sleep(time.Duration(blockSize) * (50*time.Millisecond + time.Duration(rand.Intn(5*int(time.Millisecond))))) +} diff --git a/example/sort/main.go b/example/sort/main.go index 213e41f..61a3651 100644 --- a/example/sort/main.go +++ b/example/sort/main.go @@ -27,7 +27,7 @@ defer wg.Done() blockSize := rand.Intn(maxBlockSize) + 1 for i := 0; i < 100; i++ { - time.Sleep(time.Duration(blockSize) * (50*time.Millisecond + time.Duration(rand.Intn(5*int(time.Millisecond))))) + sleep(blockSize) bar1.Incr(1) blockSize = rand.Intn(maxBlockSize) + 1 } @@ -41,7 +41,7 @@ defer wg.Done() blockSize := rand.Intn(maxBlockSize) + 1 for i := 0; i < 60; i++ { - time.Sleep(time.Duration(blockSize) * (50*time.Millisecond + time.Duration(rand.Intn(5*int(time.Millisecond))))) + sleep(blockSize) bar2.Incr(1) blockSize = rand.Intn(maxBlockSize) + 1 } @@ -55,7 +55,7 @@ defer wg.Done() blockSize := rand.Intn(maxBlockSize) + 1 for i := 0; i < 80; i++ { - time.Sleep(time.Duration(blockSize) * (50*time.Millisecond + time.Duration(rand.Intn(5*int(time.Millisecond))))) + sleep(blockSize) bar3.Incr(1) blockSize = rand.Intn(maxBlockSize) + 1 } @@ -73,3 +73,7 @@ return fmt.Sprintf("%-7s", str) } } + +func sleep(blockSize int) { + time.Sleep(time.Duration(blockSize) * (50*time.Millisecond + time.Duration(rand.Intn(5*int(time.Millisecond))))) +}