concurrency

README

concurrency

The basic go concurrency implement.

Example

Example

Documentation

Index

• type Engine
  • func New(workerNum int, newWorkerFunc NewWorkerFunc) *Engine
  • func (e *Engine) Close()
  • func (e *Engine) Run()
  • func (e *Engine) Submit(ctx context.Context)
• type NewWorkerFunc
• type Worker

Types

type Engine

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

Engine implement a concurrent engine. You can use Engine do many tasks concurrent.

func New

func New(
	workerNum int,
	newWorkerFunc NewWorkerFunc,
) *Engine

func (*Engine) Close

func (e *Engine) Close()

Close close Engine, and you cant reuse or relaunch Engine.

func (*Engine) Run

func (e *Engine) Run()

Run is represent launch engine and listening context.

func (*Engine) Submit

func (e *Engine) Submit(ctx context.Context)

Submit a context to Engine, it will be received while any Worker ready.

type NewWorkerFunc

type NewWorkerFunc func() Worker

NewWorkerFunc represents the method to create a practical Worker.

type Worker

type Worker interface {
	Do(ctx context.Context)
}

Worker represents who can handle context.