concurrent

Documentation

Index

• Constants
• func IterateInParallel(items []interface{}, iterator func(order interface{}))
• func NewAsyncBuffer(executionCallback func([]interface{}), config ...int) *asyncBuffer
• func NewFlag() system.Flag
• func Parallel(functions ...func())
• func StartSingleThreadScheduledExecutor()
• type IAsyncTask
  • func NewAsyncTask(runnable func()) IAsyncTask
• type IAsyncTaskPool
  • func CreateAsyncTaskPool(lockOSThread bool) IAsyncTaskPool
  • func NewAsyncTaskPool() IAsyncTaskPool

Constants

const (
	DefaultBufferSize       = 10000
	DefaultAutoFlushTimeout = 5 * time.Second
)

Functions

func IterateInParallel

func IterateInParallel(items []interface{}, iterator func(order interface{}))

func NewAsyncBuffer

func NewAsyncBuffer(executionCallback func([]interface{}), config ...int) *asyncBuffer

func NewFlag

func NewFlag() system.Flag

func Parallel

func Parallel(functions ...func())

func StartSingleThreadScheduledExecutor

func StartSingleThreadScheduledExecutor()

Types

type IAsyncTask

type IAsyncTask interface {
	Run()
}

func NewAsyncTask

func NewAsyncTask(runnable func()) IAsyncTask

type IAsyncTaskPool

type IAsyncTaskPool interface {
	Submit(tasks ...func()) IAsyncTaskPool
	Run() IAsyncTaskPool
	Join()
}

func CreateAsyncTaskPool

func CreateAsyncTaskPool(lockOSThread bool) IAsyncTaskPool

func NewAsyncTaskPool

func NewAsyncTaskPool() IAsyncTaskPool