concurrent

README

Package concurrent

run function concurrently.

Usage

see unit test files for more examples.

package main

import (
	"errors"
	"log"
	"time"

	"github.com/QisFj/godry/concurrent"
)

func main() {
	log.Println("with error:")
	withErr()
	log.Println("no error:")
	noErr()
}

func withErr() {
	if err := concurrent.Do(
		func() error {
			time.Sleep(20 * time.Millisecond)
			return errors.New("error-1")
		},
		func() error {
			time.Sleep(20 * time.Millisecond)
			return errors.New("error-1")
		},
		func() error {
			time.Sleep(20 * time.Millisecond)
			return errors.New("error-2")
		},
	); err != nil {
		log.Printf("err: %s\n", err)
	} else {
		log.Println("no error")
	}
}

func noErr() {
	if err := concurrent.Do(
		func() error {
			time.Sleep(20 * time.Millisecond)
			return nil
		},
		func() error {
			time.Sleep(20 * time.Millisecond)
			return nil
		},
		func() error {
			time.Sleep(20 * time.Millisecond)
			return nil
		},
	); err != nil {
		log.Printf("err: %s\n", err)
	} else {
		log.Println("no error")
	}
}

Documentation

Index

• func Do(functions ...FuncMayError) error
• func Foreach(slice interface{}, f func(i int, v interface{}) error) error
• func Merge(eachFuncs []EachFunc, merge MergeFunc) error
• func MergeForeach(slice interface{}, f func(i int, v interface{}) (interface{}, error), ...) error
• type EachFunc
• type FuncMayError
• type Limiter
  • func NewLimiter(n int) *Limiter
  • func (l *Limiter) Acquire()
  • func (l *Limiter) Release()
• type MergeFunc

Functions

func Do

func Do(functions ...FuncMayError) error

func Foreach

func Foreach(slice interface{}, f func(i int, v interface{}) error) error

func Merge

func Merge(eachFuncs []EachFunc, merge MergeFunc) error

func MergeForeach

func MergeForeach(slice interface{}, f func(i int, v interface{}) (interface{}, error), merge MergeFunc) error

Types

type EachFunc

type EachFunc func() (interface{}, error)

type FuncMayError

type FuncMayError func() error

type Limiter

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

wrap sync.Cond on a uint, use to limit concurrent

zero value is not read to use, use NewLimiter to create

func NewLimiter

func NewLimiter(n int) *Limiter

func (*Limiter) Acquire

func (l *Limiter) Acquire()

func (*Limiter) Release

func (l *Limiter) Release()

type MergeFunc

type MergeFunc func(i int, v interface{}) error