asynctask

Documentation

Index

• type AsyncTask
  • func GetNamedAsyncTask(name string, taskChanNumber int64, goNumber int, onError func(err error)) (*AsyncTask, error)
  • func (t *AsyncTask) Close()
  • func (t *AsyncTask) Post(tasks ...IAsyncTask)
• type IAsyncTask

Examples

• AsyncTask.Post

Types

type AsyncTask

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

func GetNamedAsyncTask

func GetNamedAsyncTask(name string, taskChanNumber int64, goNumber int, onError func(err error)) (*AsyncTask, error)

func (*AsyncTask) Close

func (t *AsyncTask) Close()

func (*AsyncTask) Post

func (t *AsyncTask) Post(tasks ...IAsyncTask)

Example

asyncTask, err := GetNamedAsyncTask("async.task.test", 3, 3, func(err error) {
	fmt.Println("Run err", err.Error())
})
if err != nil {
	println("err", err.Error())
	return
}

asyncTask.Post(newTestTask("hello"), newTestTask("err"))
asyncTask.Close()

Output:

Run err wo qu err le

type IAsyncTask

type IAsyncTask interface {
	Run() error
}