Multitask

Multi task for golang

Features

• Support multitasking efficiently.
• Flexible and easy to use, easy to use

Usage

See more at Example.

package main

import (
	"errors"
	"fmt"
	"github.com/mhtshhp/multitask"
	"time"
)

func dosamething0() (interface{}, error) {
	// dosamething
	time.Sleep(time.Second)
	return nil, nil
}

func dosamething1() (interface{}, error) {
	// dosamething
	time.Sleep(2 * time.Second)
	return nil, nil
}

func dosamething2() (interface{}, error) {
	// dosamething
	panic(errors.New("unknown error"))
	return nil, nil
}

func main() {

	var (
		results    []*multitask.Value
		err        error
		timeout    = 100 * time.Millisecond
		concurrent = multitask.WithOptionOfQuantityPreExecution(2)
	)

	// Different calling methods are supported

	// single task usage
	// 1
	results, err = multitask.NewTask(timeout, concurrent).Excute(multitask.WithParamsOfSingleFunc(dosamething0))
	if err != nil {
		handleError(err)
	}
	iterator(results)

	// multi task usage
	// 2
	results, err = multitask.NewTask(timeout, concurrent).Excute(multitask.WithParamsOfMultiFunc(dosamething0, dosamething1, dosamething2))
	if err != nil {
		handleError(err)
	}
	iterator(results)

	// 3
	results, err = multitask.NewTask(timeout, concurrent).Excute(multitask.WithParamsOfFuncMap([]multitask.MultitaskFunc{dosamething0, dosamething1, dosamething2}))
	if err != nil {
		handleError(err)
	}
	iterator(results)

	// 4
	fns := make([]multitask.MultitaskFunc, 3)
	fns[0] = dosamething0
	fns[1] = dosamething1
	fns[2] = dosamething2
	results, err = multitask.NewTask(timeout, concurrent).Excute(fns)
	if err != nil {
		handleError(err)
	}
	iterator(results)

}

func handleError(err error) {
	fmt.Printf("[ERROR]:%v \n", err)
}

func iterator(assemble []*multitask.Value) {
	for k, v := range assemble {
		fmt.Printf("[M][ID]:%d, [ExcutionTime]:%s, [Error]:%v, [DATA]:%v \n", k, v.ExcutionTime, v.Error, v.Data)
	}
}

License

Released under the MIT License.