Documentation
¶
Index ¶
Examples ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var DefaultGraceful = Graceful{/* contains filtered or unexported fields */}
DefaultGraceful 默认的Graceful
Functions ¶
func Parallel ¶
Parallel 并行执行一组函数，等待执行完成。 如果其中一个或多个函数返回错误，未执行的函数不再执行，并优先选择前面函数的错误返回。 如果其中一个或多个函数panic，未执行的函数不再执行，并优先选择前面函数的recover()的非nil结果再次panic。
Example ¶
err := Parallel(func() error {
fmt.Println("I am a concurrently executed task")
return nil
}, func() error {
fmt.Println("I am a concurrently executed task")
return nil
}, func() error {
fmt.Println("I am a concurrently executed task")
return fmt.Errorf("a little exception")
})
if err != nil {
fmt.Println(err)
}
Output: I am a concurrently executed task I am a concurrently executed task I am a concurrently executed task a little exception
func ParallelLimit ¶
ParallelLimit 并行执行一组函数，等待执行完成。 每次调用最多只执行limit路并发执行。前面的函数优先执行。 如果其中一个或多个函数返回错误，未执行的函数不再执行，并优先选择前面函数的错误返回。 如果其中一个或多个函数panic，未执行的函数不再执行，并优先选择前面函数的recover()的非nil结果再次panic。
func Series ¶
Series 串行执行一组函数，直至出错或者执行完。
Example ¶
err := Series(func() error {
fmt.Println("one")
return nil
}, func() error {
fmt.Println("two")
return nil
}, func() error {
fmt.Println("three")
return fmt.Errorf("Failed")
}, func() error {
fmt.Println("four")
return nil
})
if err != nil {
fmt.Println(err)
}
Output: one two three Failed
Types ¶
type Graceful ¶
type Graceful struct {
// contains filtered or unexported fields
}
Graceful 运行并graceful退出。
Example ¶
go func() {
DefaultGraceful.Run(func() {
// nothing
})
}()
branch := DefaultGraceful.NewBranch("branch_1")
go func() {
branch.Run(func() {
time.Sleep(time.Millisecond * 500)
})
}()
// 等待两个goroutine已经运行
time.Sleep(time.Millisecond * 100)
// 程序退出时……
ctx, cancel := context.WithTimeout(context.Background(), time.Millisecond*100)
defer cancel()
err := DefaultGraceful.Wait(ctx)
if err != nil {
fmt.Println(err)
busyBranches := DefaultGraceful.BusyBranches()
fmt.Println(busyBranches)
// 直接结束进程，不再等待分支Run的过程
}
Output: context deadline exceeded [branch_1]
func (*Graceful) BusyBranches ¶
BusyBranches 忙碌中的分支。
Source Files
Click to show internal directories.
Click to hide internal directories.