pooling

README

pooling

pooling for gorotine

Documentation

Index

• type IPool
• type MockedGPoolingImpl
  • func (p *MockedGPoolingImpl) Release()
  • func (p *MockedGPoolingImpl) Running() int
  • func (p *MockedGPoolingImpl) Submit(task func())
• type Pool
  • func Init(maxPoolSize int, logger logger.ILogger) (*Pool, error)
  • func (p *Pool) Release()
  • func (p *Pool) Running() int
  • func (p *Pool) Submit(task func())

Types

type IPool

type IPool interface {
	Submit(task func())
	Release()
	Running() int
}

IPool - pooling interface

type MockedGPoolingImpl

type MockedGPoolingImpl struct {
}

MockedGPoolingImpl - mocking

func (*MockedGPoolingImpl) Release

func (p *MockedGPoolingImpl) Release()

Release - release all gorotine

func (*MockedGPoolingImpl) Running

func (p *MockedGPoolingImpl) Running() int

Running - returns the number of the currently running goroutines.

func (*MockedGPoolingImpl) Submit

func (p *MockedGPoolingImpl) Submit(task func())

Submit - submit a task to this pool

type Pool

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

Pool - pooling struct

func Init

func Init(maxPoolSize int, logger logger.ILogger) (*Pool, error)

Init - init pooling

func (*Pool) Release

func (p *Pool) Release()

Release - release all gorotine

func (*Pool) Running

func (p *Pool) Running() int

Running - returns the number of the currently running goroutines.

func (*Pool) Submit

func (p *Pool) Submit(task func())

Submit - submit a task to this pool