action_plan_apply_fn.go

package action

import (
	"sync"
)

// ApplyFunction is a function which applies an action
type ApplyFunction func(Interface) error

// WrapSequential wraps apply function to be sequential
func WrapSequential(fn ApplyFunction) ApplyFunction {
	mutex := sync.Mutex{}
	return func(act Interface) error {
		mutex.Lock()
		defer mutex.Unlock()
		return fn(act)
	}
}

// WrapParallelWithLimit allows to run the provided function in parallel, but in no more than maxConcurrentGoRoutines
// concurrent go routines
func WrapParallelWithLimit(maxConcurrentGoRoutines int, fn ApplyFunction) ApplyFunction {
	var semaphore = make(chan int, maxConcurrentGoRoutines)
	return func(act Interface) error {
		semaphore <- 1
		defer func() { <-semaphore }()
		return fn(act)
	}
}

// Noop returns a function that does nothing and returns nil
func Noop() ApplyFunction {
	return func(Interface) error { return nil }
}