diff options
| author | chrislu <chris.lu@gmail.com> | 2022-09-25 17:42:23 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2022-09-25 17:43:42 -0700 |
| commit | 640c53cda82da903d984b5190a1bdd414499942b (patch) | |
| tree | 5f59a3bcadc49365a172daba9baf72d9240c21d9 /weed/util/limited_async_pool_test.go | |
| parent | cc570a4477a791312355dfd325a49bd276522997 (diff) | |
| download | seaweedfs-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.go | 16 |
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) } |
