sync

Documentation

Index

• type ShardJob
• type ShardWorkerPool
  • func NewShardWokerPool(size int, numShards int, workerFunc WorkerFunc) (ShardWorkerPool, error)
• type WorkerFunc
• type WorkerPool
  • func NewWorkerPool(size int) WorkerPool

Types

type ShardJob

type ShardJob interface {
	Source() uint32
}

type ShardWorkerPool

type ShardWorkerPool interface {
	Init()

	Shard(source uint32) uint32

	Offer(job ShardJob, block bool)
}

func NewShardWokerPool

func NewShardWokerPool(size int, numShards int, workerFunc WorkerFunc) (ShardWorkerPool, error)

type WorkerFunc

type WorkerFunc func(shard int, jobCh <-chan interface{})

type WorkerPool

type WorkerPool interface {
	Schedule(task func())

	ScheduleAlways(task func())

	ScheduleAuto(task func())
}

func NewWorkerPool

func NewWorkerPool(size int) WorkerPool