multiexecutor

Documentation

Overview

Package multiexecutor provides a structure MultiExecutor that can be used to guarantee exclusive by ID, in order execution of functions.

Index

• type MultiExecutor
  • func (e *MultiExecutor) AsyncExec(id string, f func()) (ch <-chan struct{})

Types

type MultiExecutor

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

MultiExecutor - a struct that can be used to guarantee exclusive by ID, in order execution of functions.

func (*MultiExecutor) AsyncExec

func (e *MultiExecutor) AsyncExec(id string, f func()) (ch <-chan struct{})

AsyncExec - guarantees f() will be executed Exclusively for specified ID and in the Order submitted.

It immediately returns a channel that will be closed when f() has completed execution.