aboutsummaryrefslogtreecommitdiff
path: root/weed/util/limited_async_pool_test.go
diff options
context:
space:
mode:
authorchrislu <chris.lu@gmail.com>2022-09-25 17:42:23 -0700
committerchrislu <chris.lu@gmail.com>2022-09-25 17:43:42 -0700
commit640c53cda82da903d984b5190a1bdd414499942b (patch)
tree5f59a3bcadc49365a172daba9baf72d9240c21d9 /weed/util/limited_async_pool_test.go
parentcc570a4477a791312355dfd325a49bd276522997 (diff)
downloadseaweedfs-640c53cda82da903d984b5190a1bdd414499942b.tar.xz
seaweedfs-640c53cda82da903d984b5190a1bdd414499942b.zip
add future list
Diffstat (limited to 'weed/util/limited_async_pool_test.go')
-rw-r--r--weed/util/limited_async_pool_test.go16
1 files changed, 8 insertions, 8 deletions
diff --git a/weed/util/limited_async_pool_test.go b/weed/util/limited_async_pool_test.go
index 935b158da..090ce5375 100644
--- a/weed/util/limited_async_pool_test.go
+++ b/weed/util/limited_async_pool_test.go
@@ -10,17 +10,17 @@ import (
func TestAsyncPool(t *testing.T) {
p := NewLimitedAsyncExecutor(3)
- var results []Future
- results = append(results, p.Execute(FirstFunc))
- results = append(results, p.Execute(SecondFunc))
- results = append(results, p.Execute(ThirdFunc))
- results = append(results, p.Execute(FourthFunc))
- results = append(results, p.Execute(FifthFunc))
+ p.Execute(FirstFunc)
+ p.Execute(SecondFunc)
+ p.Execute(ThirdFunc)
+ p.Execute(FourthFunc)
+ p.Execute(FifthFunc)
var sorted_results []int
- for _, r := range results {
- x := r.Await().(int)
+ for i := 0; i < 5; i++ {
+ f := p.NextFuture()
+ x := f.Await().(int)
println(x)
sorted_results = append(sorted_results, x)
}