README
¶
go task engine
A multi-coroutine task processing engine.
What?
Recently, i'm working on handling multi-tasks in multi-coroutines.
There are many types of tasks, like A,B,C. The handle method is different if the type of task is different. When requests are coming, i need handle them in multi-coroutines.
How?
This is similar to a factory although i have never seen.
It should be like this: There are some conveyors is rolling in a factory. There are some workers working on the conveyor belt. They handle the rolling parts on the conveyor belt. Different parts are placed on different conveyor belts
Future
It's not good enough yet, welcome issue or pr.
Documentation
¶
Index ¶
Constants ¶
const ( StatusNew = iota StatusRun StatusStop )
status from StatusNew to StatusStopped, no loop.
Variables ¶
var ErrLineIsFull = errors.New("too many tasks, add a worker please")
ErrLineIsFull conveyor is full, can not puts any part. Client judges whether to add more workers according to the CPU's load.
var ErrLineStopped = errors.New("the conveyor is stopped")
var ErrUnallowed = errors.New("the factory is not allowed to add new conveyor")
Functions ¶
This section is empty.
Types ¶
type IConveyor ¶
type IConveyor interface {
// PutPart puts parts on conveyor belt, if a conveyor is full, return ErrLineIsFull.
PutPart(p Part, duration time.Duration) error
// GetPart return a part and the status of conveyor if closed.
GetPart() (Part, bool)
// Run lets the conveyor rolling.
Run()
// Stop stops a conveyor.
Stop()
}
ConveyorI receives parts, and workers take parts from it.
type IFactory ¶
type IFactory interface {
// AddLine add conveyor to the factory.
AddLine(name string, c IConveyor) error
// Run lets all conveyors running.
Run()
// Stop lets all conveyors stop.
Stop()
// GetLine
GetLine(name string) IConveyor
}
func NewFactory ¶
func NewFactory() IFactory
type IWorker ¶
type IWorker interface {
Working()
Stop()
}
Worker - worker take parts from conveyor and handle them.
type TConveyor ¶
type TConveyor struct {
StopSignC chan struct{} // receive stop signal.
// contains filtered or unexported fields
}
type TFactory ¶
type TFactory struct {
// contains filtered or unexported fields
}
emptyFactory a instance of Factory interface
Source Files