syncex

Documentation

Index

• func Collect(errchans ...<-chan error) <-chan error
• func CollectContext(ctx context.Context, errchans ...<-chan error) <-chan error
• type Counter
  • func (c *Counter) Add(delta int64)
  • func (c *Counter) Dec()
  • func (c *Counter) Inc()
  • func (c *Counter) Reset()
  • func (c *Counter) Value() int64
• type Semaphore
  • func NewSemaphore(initialCount int) *Semaphore
  • func (s *Semaphore) Acquire()
  • func (s *Semaphore) AcquireTimeout(timeout time.Duration) bool
  • func (s *Semaphore) Release()

Examples

• Collect

Functions

func Collect

func Collect(errchans ...<-chan error) <-chan error

Example

doWork := func(url string) chan error {
	errs := make(chan error)
	go func(url string) {
		// Some expensive work..
		_, err := http.Get(url)
		if err != nil {
			errs <- err
		}
	}(url)
	return errs
}

for err := range Collect(
	doWork("1"),
	doWork("2"),
) {
	if err != nil {
		fmt.Println("Error:", err)
	}
}

func CollectContext

func CollectContext(ctx context.Context, errchans ...<-chan error) <-chan error

Types

type Counter

type Counter struct {
	// contains filtered or unexported fields
}

func (*Counter) Add

func (c *Counter) Add(delta int64)

func (*Counter) Dec

func (c *Counter) Dec()

func (*Counter) Inc

func (c *Counter) Inc()

func (*Counter) Reset

func (c *Counter) Reset()

func (*Counter) Value

func (c *Counter) Value() int64

type Semaphore

type Semaphore struct {
	// contains filtered or unexported fields
}

func NewSemaphore

func NewSemaphore(initialCount int) *Semaphore

func (*Semaphore) Acquire

func (s *Semaphore) Acquire()

func (*Semaphore) AcquireTimeout

func (s *Semaphore) AcquireTimeout(timeout time.Duration) bool

func (*Semaphore) Release

func (s *Semaphore) Release()