README
¶
asyncio
并发异步库
使用
package asyncio_test
import (
"fmt"
"math"
"testing"
"time"
"github.com/Drelf2018/asyncio"
)
func sleep(second int) float64 {
time.Sleep(time.Duration(second) * time.Second)
return math.Sqrt(float64(second))
}
type Student struct {
Name string
}
func (s Student) Introduce(more string) {
time.Sleep(time.Duration(2) * time.Second)
println("My name is", s.Name, "and", more)
}
func (s Student) Hello() {
print("Hello ")
}
func (s Student) Me() {
time.Sleep(time.Second)
println(s.Name)
}
func TestSleep(t *testing.T) {
handles := asyncio.Slice(asyncio.SingleArg(1, 2, 3, 4), sleep)
// need hint type
a := asyncio.To[[]float64](handles)
fmt.Printf("a: %v\n", a)
// auto infer
b := make([]float64, handles.Len())
asyncio.To(handles, b)
fmt.Printf("b: %v\n", b)
for i, handle := range handles {
fmt.Printf("No.%v sleep() return %v\n", i, handle.Result())
}
}
func TestStruct(t *testing.T) {
s := Student{"Alice"}
coro := asyncio.C(s.Introduce, "I'm glad to see you!")
coros := asyncio.NoArgsFunc(s.Hello, s.Me)
asyncio.Await(append(coros, coro)...)
}
控制台
// TestSleep
a: [1 1.4142135623730951 1.7320508075688772 2]
b: [1 1.4142135623730951 1.7320508075688772 2]
No.0 sleep() return [1]
No.1 sleep() return [1.4142135623730951]
No.2 sleep() return [1.7320508075688772]
No.3 sleep() return [2]
// TestStruct
Hello Alice
My name is Alice and I'm glad to see you!
Documentation
¶
Index ¶
- Variables
- func Delay(seconds float64, fn any, args ...any)
- func Fill[S ~[]E, E any](tasks []*Task, s S, position ...int)
- func ForEach[S ~[]E, E any](args S, f func(E))
- func ForEachPtr[S ~[]E, E any](args S, f func(*E))
- func ForEachPtrV[S ~[]E, E any, V any](args S, f func(*E) V) []V
- func ForEachV[S ~[]E, E any, V any](args S, f func(E) V) []V
- func ForFunc[E any](arg E, f ...func(E))
- func ForFuncV[E any, V any](arg E, f ...func(E) V) []V
- func Loop(f func(loop EventLoop))
- func Map[M ~map[K]V, K comparable, V any](m M, f func(K, V))
- func MapR[M ~map[K]V, K comparable, V any, R any](m M, f func(K, V) R) []R
- func Promise(fn any, args ...any) (p *promise)
- func PromiseTask(task *Task) *promise
- func Results[E any](tasks []*Task, position ...int) []E
- func Retry(times int, delay float64, f func() bool) bool
- func RetryError(times int, delay float64, f func() error) bool
- func RetryErrorTask(times int, delay float64, task *Task) bool
- func RetryTask(times int, delay float64, task *Task) bool
- func RunForever(tasks ...*Task)
- func RunUntilComplete(tasks ...*Task)
- func SetEventLoop(fn func() EventLoop)
- func Wait(tasks ...*Task)
- func WaitGroup(delta int, f func(done func()))
- type AbstractEventLoop
- func (loop *AbstractEventLoop) CreateTask(fn any, args ...any) (r *Task)
- func (loop *AbstractEventLoop) Finish()
- func (loop *AbstractEventLoop) Run(task *Task)
- func (loop *AbstractEventLoop) RunForever(tasks ...*Task)
- func (loop *AbstractEventLoop) RunUntilComplete(tasks ...*Task)
- func (loop *AbstractEventLoop) Start()
- func (loop *AbstractEventLoop) Stop()
- type EventLoop
- type Status
- type Task
- func (t *Task) AddDoneCallback(c func(*Task)) *Task
- func (t *Task) Bool() bool
- func (t *Task) Bool2() bool
- func (t *Task) Check() bool
- func (t *Task) Check2() bool
- func (t *Task) Copy(args ...any) *Task
- func (t *Task) Default(args ...any) *Task
- func (t *Task) Delay(seconds float64) *Task
- func (t *Task) Done() bool
- func (t *Task) Error() error
- func (t *Task) Error2() error
- func (t *Task) First() any
- func (t *Task) Reflect(args reflect.Value) *Task
- func (t *Task) Result() []any
- func (t *Task) Run() *Task
- func (t *Task) Second() any
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrNoResult = errors.New("task has no rusult") ErrNoSecondResult = errors.New("task has no second rusult") )
View Source
var NewEventLoop = func() EventLoop { return &AbstractEventLoop{ status: Stop, tasks: sync.WaitGroup{}, } }
Functions ¶
func ForEachPtr ¶ added in v0.12.0
func ForEachPtr[S ~[]E, E any](args S, f func(*E))
func ForEachPtrV ¶ added in v0.13.0
func Map ¶
func Map[M ~map[K]V, K comparable, V any](m M, f func(K, V))
func MapR ¶ added in v0.13.0
func MapR[M ~map[K]V, K comparable, V any, R any](m M, f func(K, V) R) []R
func PromiseTask ¶ added in v0.12.0
func PromiseTask(task *Task) *promise
func RetryError ¶
重试函数 通过是否抛出 error 判断
func RetryErrorTask ¶ added in v0.12.0
重试函数 通过是否抛出 error 判断 支持参数
func RunForever ¶ added in v0.12.0
func RunForever(tasks ...*Task)
func RunUntilComplete ¶ added in v0.12.0
func RunUntilComplete(tasks ...*Task)
func SetEventLoop ¶
func SetEventLoop(fn func() EventLoop)
Types ¶
type AbstractEventLoop ¶
type AbstractEventLoop struct {
// contains filtered or unexported fields
}
func (*AbstractEventLoop) CreateTask ¶
func (loop *AbstractEventLoop) CreateTask(fn any, args ...any) (r *Task)
func (*AbstractEventLoop) Finish ¶ added in v0.12.0
func (loop *AbstractEventLoop) Finish()
func (*AbstractEventLoop) Run ¶ added in v0.7.0
func (loop *AbstractEventLoop) Run(task *Task)
func (*AbstractEventLoop) RunForever ¶
func (loop *AbstractEventLoop) RunForever(tasks ...*Task)
func (*AbstractEventLoop) RunUntilComplete ¶
func (loop *AbstractEventLoop) RunUntilComplete(tasks ...*Task)
func (*AbstractEventLoop) Start ¶ added in v0.12.0
func (loop *AbstractEventLoop) Start()
func (*AbstractEventLoop) Stop ¶ added in v0.12.0
func (loop *AbstractEventLoop) Stop()
type EventLoop ¶ added in v0.12.0
type EventLoop interface {
CreateTask(fn any, args ...any) *Task
Run(task *Task)
Start()
RunUntilComplete(tasks ...*Task)
RunForever(tasks ...*Task)
Stop()
}
func GetEventLoop ¶
func GetEventLoop() EventLoop
type Task ¶
type Task struct {
Func reflect.Value
Args []reflect.Value
// contains filtered or unexported fields
}
func CreateTask ¶ added in v0.12.0
func (*Task) AddDoneCallback ¶ added in v0.12.0
Source Files
Click to show internal directories.
Click to hide internal directories.