pool

Documentation

Index

• type ActorPool
  • func NewActorPool(system *actor.System, queueLimit uint, workersLimit uint, name string, ...) ActorPool
  • func (p *ActorPool) Receive(ctx *actor.Context) error
  • func (p *ActorPool) SubmitTask(task interface{}) error
• type QueueFullError
  • func (e QueueFullError) Error() string

Types

type ActorPool

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

ActorPool implements thread-pool like behavior in the actor system. It is given a function to handle tasks, and will call this function with each task submitted to the actor pool.

func NewActorPool

func NewActorPool(
	system *actor.System,
	queueLimit uint,
	workersLimit uint,
	name string,
	taskHandler func(actorId uint64, task interface{}, ctx *actor.Context) interface{},
	callback func(result interface{}),
) ActorPool

NewActorPool initializes a new actor pool and starts its manager actor.

func (*ActorPool) Receive

func (p *ActorPool) Receive(ctx *actor.Context) error

Receive handles all the messages for the actor pool manager.

func (*ActorPool) SubmitTask

func (p *ActorPool) SubmitTask(task interface{}) error

SubmitTask is a convenience function for sending a task to the actor pool's manager actor.

type QueueFullError

type QueueFullError struct{}

QueueFullError is returned by SubmitTask when the pool is so backed up that the queue is full.

func (QueueFullError) Error

func (e QueueFullError) Error() string