molix

README

Molix

灵感来自

Documentation

Index

• Variables
• func Cap() int
• func Free() int
• func Running() int
• func Stop()
• func Submit(t func()) error
• type MPool
  • func NewMPool(size int32) (*MPool, error)
  • func (m *MPool) Cap() int
  • func (m *MPool) Free() int
  • func (m *MPool) Running() int
  • func (m *MPool) Stop()
  • func (m *MPool) Submit(t func()) error
• type MTask
• type Status

Variables

var (
	ErrPoolCap          = errors.New("invalid size for pool")
	ErrPoolAlreadyStope = errors.New("pool already stoped")
)

Functions

func Cap

func Cap() int

func Free

func Free() int

func Running

func Running() int

func Stop

func Stop()

func Submit

func Submit(t func()) error

Types

type MPool

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

func NewMPool

func NewMPool(size int32) (*MPool, error)

func (*MPool) Cap

func (m *MPool) Cap() int

func (*MPool) Free

func (m *MPool) Free() int

func (*MPool) Running

func (m *MPool) Running() int

func (*MPool) Stop

func (m *MPool) Stop()

func (*MPool) Submit

func (m *MPool) Submit(t func()) error

type MTask

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

type Status

type Status int32

const (
	RUNNING Status = iota
	STOPED
)