go-future
This library helps to use goroutines and wait for result.
Usage example
Single Future
Anonymous Function usage
fut := future.Run(func() (string, error) {
time.Sleep(1000 * time.Millisecond)
return "name", nil
})
// do anything ...
// wait until the process is complete and getResult
result := fut.GetResult()
Handle error
result, err := fut.Get()
if err != nil {
println("An error occurred.")
}
Function Ref
fut := future.Run(execute)
result := fut.GetResult()
func execute() (string, error) {
time.Sleep(1000 * time.Millisecond)
return "name", nil
}
With Single Param
fut := future.RunWithParam(execute, "str-param")
result := fut.GetResult()
func execute(strParam string) (string, error) {
time.Sleep(1000 * time.Millisecond)
return strParam, nil
}
With Multi Param
fut := future.RunWithParam(execute, future.Params{"str-param", true, 10})
result := fut.GetResult()
func execute(params future.Params) (string, error) {
time.Sleep(1000 * time.Millisecond)
param1 := params.GetStringParam(0)
param2 := params.GetBoolParam(1)
param3, _ := future.GetParam[int](params, 2) // alternative
return fmt.Sprintf("%s_%t_%d", param1, param2, param3), nil
}
Multiple Future
Future Group
ids := []string{"A", "B", "C", "D", "E"}
fg := future.Group[string]{}
for i := range ids {
id := ids[i]
fg.Go(func() (string, error) {
return APICall(id)
})
}
log.Println("Waiting for future result...")
results, err := fg.Get()
Parallel request example
ids := []string{"A", "B", "C", "D", "E"}
futures := make([]*future.Future[string], 5)
for i := range ids {
id := ids[i]
f := future.Run(func() (string, error) {
return APICall(id)
})
futures[i] = f
}
// wait all until the process is complete and getResult
results, err := future.GetAll(futures)
Parallel request different result example
fut1 := future.Run(func() (any, error) {
return GetValueA()
})
fut2 := future.Run(func() (any, error) {
return GetValueB()
})
log.Println("Waiting for future result...")
err := future.WaitFor(fut1, fut2)
if err != nil {
log.Println("An error occurred...")
return
}
result1 := future.GetResult[string](fut1)
result2 := future.GetResult[int64](fut2)