xsync

README

xsync

simple and powerful sync package

example

package main

import (
	"fmt"
	"time"

	"github.com/adwpc/xsync"
)

func main() {
    swg := xsync.NewXWaitGroup()
	swg.Add(1)
	go func() {
		time.Sleep(5 * time.Second) // simulate a long task
		swg.Done()
	}()
	// swg.Done() // extra Done call, will not cause panic
	if swg.Wait(3 * time.Second) {
		fmt.Println("Timed out")
	} else {
		fmt.Println("XWaitGroup finished")
	}
}

Documentation

Index

• type XWaitGroup
  • func NewXWaitGroup() *XWaitGroup
  • func (swg *XWaitGroup) Add(delta int)
  • func (swg *XWaitGroup) Done()
  • func (swg *XWaitGroup) Wait(timeout time.Duration) bool

Types

type XWaitGroup

type XWaitGroup struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewXWaitGroup

func NewXWaitGroup() *XWaitGroup

func (*XWaitGroup) Add

func (swg *XWaitGroup) Add(delta int)

func (*XWaitGroup) Done

func (swg *XWaitGroup) Done()

func (*XWaitGroup) Wait

func (swg *XWaitGroup) Wait(timeout time.Duration) bool