Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

concurrentloop

package module

Go to main page

Versions in this module

v1

v1.4.2

Aug 29, 2025

v1.4.1

Aug 29, 2025

v1.4.0

Aug 29, 2025

Changes in this version

type Func

+ func WithWriter(w io.Writer) Func

+ type MapMFuncCh func(ctx context.Context, key string, item T, perCycleCh chan<- Result, ...) (Result, error)

type Option

+ Writer io.Writer

v1.3.5

Nov 10, 2024

v1.3.4

Oct 26, 2024

v1.3.3

Oct 26, 2024

Changes in this version

type Errors

+ func MapDone[T any, Result any](ctx context.Context, items []T, f MapFuncCh[T, Result], opts ...Func) ([]Result, Errors)

+ type MapFuncCh func(ctx context.Context, item T, done chan<- struct{}) (Result, error)

v1.3.2

Oct 8, 2024

v1.3.1

Oct 8, 2024

v1.3.0

Aug 8, 2024

Changes in this version

+ func SplitSlice[T any](items []T, batchSize int) [][]T

v1.2.5

Mar 16, 2024

Changes in this version

+ func Flatten2D[T any](data [][]T) []T

v1.2.4

Jul 6, 2023

Changes in this version

+ const Name

v1.2.3

Jul 6, 2023

v1.2.2

Jun 22, 2023

v1.2.1

Jun 22, 2023

Changes in this version

type Func

+ func WithRandomDelayTime(min, max int, d time.Duration) Func

type Option

+ RandomDelayTimeDuration time.Duration

+ RandomDelayTimeMax int

+ RandomDelayTimeMin int

v1.2.0

Jun 14, 2023

Changes in this version

type Func

+ func WithBatchSize(concurrency int) Func

type Option

+ BatchSize int

v1.1.14

Jun 13, 2023

Changes in this version

type Errors

+ func MapM(ctx context.Context, itemsMap map[string]T, f MapMFunc[T, Result], ...) ([]Result, Errors)

+ type MapMFunc func(ctx context.Context, key string, item T) (Result, error)

v1.1.13

Jun 8, 2023

v1.1.12

Jun 8, 2023

Changes in this version

type Func

+ func WithLimit(limit int) Func

type Option

+ Limit int

v1.1.11

May 20, 2023

Changes in this version

type Func

+ func WithRemoveZeroValues(remove bool) Func

v1.1.10

May 20, 2023

v1.1.9

May 20, 2023

Changes in this version

+ func IsZeroOfUnderlyingType(x interface{}) bool

type Func

+ func RemoveZeroValues(remove bool) Func

type Option

+ RemoveZeroValues bool

v1.1.8

May 20, 2023

v1.1.7

May 20, 2023

Changes in this version

type Func

+ func WithConcurrency(concurrency int) Func

+ type Option struct

+ Concurrency int

v1.1.6

May 17, 2023

v1.1.5

May 17, 2023

Changes in this version

type ResultCh

+ Index int

v1.1.4

May 12, 2023

v1.1.3

Apr 7, 2023

v1.1.2

Apr 7, 2023

v1.1.1

Apr 6, 2023

Changes in this version

+ func ExecuteCh(ctx context.Context, fns []ExecuteFunc[T]) chan ResultCh[T]

+ func MapCh(ctx context.Context, sl []T, f MapFunc[T, Result]) chan ResultCh[Result]

type Errors

+ func Execute(ctx context.Context, fns []ExecuteFunc[T]) ([]T, Errors)

+ func Map(ctx context.Context, sl []T, f MapFunc[T, Result]) ([]Result, Errors)

+ type ExecuteFunc func(context.Context) (T, error)

+ type MapFunc func(context.Context, T) (Result, error)

v1.1.0

Feb 17, 2023

Changes in this version

+ func RunCh(ctx context.Context, sl []T, f Func[T, Result]) chan ResultCh[Result]

+ type Errors []error

+ func (e Errors) Error() string

+ type ResultCh struct

+ Error error

+ Output T

v1.0.1

Dec 20, 2022

Changes in this version

+ func Run(sl []T, f Func[T, Result]) ([]Result, []error)

+ type Func func(T) (Result, error)

v1.0.0

Dec 20, 2022

Changes in this version

+ func ConcurrentProcessing(sl []T, cF ConcurrentFunc[T, Result]) ([]Result, []error)

+ type ConcurrentFunc func(T) (Result, error)