README
¶
Package cloudeng.io/sync/ctxsync
import cloudeng.io/sync/ctxsync
Package ctxsync provides context aware synchronisation primitives.
Types
Type WaitGroup
type WaitGroup struct {
sync.WaitGroup
}
WaitGroup represents a context aware sync.WaitGroup
Methods
func (wg *WaitGroup) Wait(ctx context.Context)
Wait blocks until the WaitGroup reaches zero or the context is canceled, whichever comes first.
Examples
ExampleWaitGroup
Documentation
¶
Overview ¶
Package ctxsync provides context aware synchronisation primitives.
Index ¶
Examples ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type WaitGroup ¶
WaitGroup represents a context aware sync.WaitGroup
Example ¶
package main
import (
"context"
"fmt"
"time"
"cloudeng.io/sync/ctxsync"
)
func main() {
var wg ctxsync.WaitGroup
wg.Add(1)
ctx, cancel := context.WithCancel(context.Background())
go func() {
time.Sleep(time.Second)
cancel()
}()
wg.Wait(ctx)
fmt.Println(ctx.Err())
}
Output: context canceled
Source Files
Click to show internal directories.
Click to hide internal directories.