thread

Documentation

Index

• type Pool_client
  • func Pool(ctx context.Context, max int) *Pool_client
  • func (object *Pool_client) Join()
  • func (object *Pool_client) Run(task Task)
  • func (object *Pool_client) Timer(ctx context.Context)
  • func (object *Pool_client) Write(task Task)
• type Task

Types

type Pool_client

type Pool_client struct {
	Max     int
	Run_num int
	Ctx     context.Context
}

func Pool

func Pool(ctx context.Context, max int) *Pool_client

func (*Pool_client) Join

func (object *Pool_client) Join()

func (*Pool_client) Run

func (object *Pool_client) Run(task Task)

func (*Pool_client) Timer

func (object *Pool_client) Timer(ctx context.Context)

func (*Pool_client) Write

func (object *Pool_client) Write(task Task)

type Task

type Task struct {
	Fun      interface{}
	Callback func(context.Context, []reflect.Value)
	Args     []interface{}
	Timeout  int
}