molixpool

Documentation

Index

• Variables
• type MTask
• type MolixPool
  • func NewMolix(max int32) (*MolixPool, error)
  • func (m *MolixPool) Close() error
  • func (m *MolixPool) GetMTask() *MTask
  • func (m *MolixPool) GetRunnins() int32
  • func (m *MolixPool) PutMTask(t *MTask)
  • func (m *MolixPool) Submit(t *MTask) error
• type Status

Variables

var (
	ErrFailPoolCap      = errors.New("fail pool cap")
	ErrPoolAlreadyStope = errors.New("pool already close")
)

Types

type MTask

type MTask struct {
	MArgs []interface{}
	MFunc func(v ...interface{})
}

type MolixPool

type MolixPool struct {
	PanicHandle func(v interface{})
	// contains filtered or unexported fields
}

func NewMolix

func NewMolix(max int32) (*MolixPool, error)

func (*MolixPool) Close

func (m *MolixPool) Close() error

func (*MolixPool) GetMTask

func (m *MolixPool) GetMTask() *MTask

func (*MolixPool) GetRunnins

func (m *MolixPool) GetRunnins() int32

func (*MolixPool) PutMTask

func (m *MolixPool) PutMTask(t *MTask)

func (*MolixPool) Submit

func (m *MolixPool) Submit(t *MTask) error

type Status

type Status int32

const (
	RUNNING Status = iota
	STOPED
)