asyncTask

package module
v0.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 26, 2022 License: MIT Imports: 8 Imported by: 0

README

Async Task

安装

go get github.com/wanghaha-dev/asyncTask

简单使用

package main

import (
	"context"
	"fmt"
	"log"

	"github.com/wanghaha-dev/asyncTask"
)

func main() {
	task, err := asyncTask.NewTask(context.Background(), asyncTask.Config{
		Addr:     "127.0.0.1:6379",
		DB:       0,
		Password: "",
	})
	if err != nil {
		panic(err)
	}

	// put task
	taskId, err := asyncTask.GenerateTaskId()
	if err != nil {
		log.Fatalln("generate taskId error!")
	}
	task.PutNormalTask(taskId, asyncTask.Map{
		"name": "task1",
		"date": asyncTask.Datetime(),
		"user": "1001",
	})

	// take task
	t1, err := task.TakeNormalTask()
	if err != nil {
		log.Fatalln("take normal task error:", err)
	}

	fmt.Println("take task is: ", t1)
	fmt.Println(t1["task_id"], t1["data"])
	fmt.Println(t1["data"].(map[string]interface{})["name"])
	jsonContext, err := t1.GetJSON()
	if err != nil {
		log.Fatalln("GetJson error: ", err)
	}
	fmt.Println(t1.GetJSON())
	// {"data":{"date":"2022-08-26 10:26:44","name":"task1","user":"1001"},"task_id":"03efb9e08b284642b5fd1ea11ae20341"}
	fmt.Println(asyncTask.JSONGet(jsonContext, "data.name"))
}

并发使用

package main

import (
	"context"
	"fmt"
	"log"
	"sync"

	"github.com/wanghaha-dev/asyncTask"
)

func main() {
	task, err := asyncTask.NewTask(context.Background(), asyncTask.Config{
		Addr:     "127.0.0.1:6379",
		DB:       0,
		Password: "",
	})
	if err != nil {
		panic(err)
	}

	var wg sync.WaitGroup
	wg.Add(200)

	// put task
	go func() {
		asyncTask.Each(100, func() {
			taskId, err := asyncTask.GenerateTaskId()
			if err != nil {
				log.Fatalln("generate taskId error!")
			}
			task.PutNormalTask(taskId, asyncTask.Map{
				"name": "task1",
				"date": asyncTask.Datetime(),
				"user": "1001",
			})

			wg.Done()
		})
	}()

	// take task
	go func() {
		asyncTask.Each(100, func() {
			t1, err := task.TakeNormalTask()
			if err != nil {
				log.Fatalln("take normal task error:", err)
			}

			fmt.Println("take task is: ", t1)

			wg.Done()
		})
	}()

	wg.Wait()
	fmt.Println("finish.")
}

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Datetime

func Datetime() string

func Each

func Each(count int, f func())

func EachStrings

func EachStrings(data []string)

func GenerateTaskId

func GenerateTaskId() (string, error)

func JSONGet

func JSONGet(jsonContext string, key string) gjson.Result

Types

type Config

type Config struct {
	Addr     string
	DB       int
	Password string
}

type Map

type Map map[string]interface{}

func (Map) GetJSON

func (m Map) GetJSON() (string, error)

type Task

type Task struct {
	RedisClient *redis.Client
	// contains filtered or unexported fields
}

func NewTask

func NewTask(ctx context.Context, config Config) (*Task, error)

func (*Task) GetFailTaskLength

func (t *Task) GetFailTaskLength() (int64, error)

func (*Task) GetFailTaskList

func (t *Task) GetFailTaskList() ([]string, error)

func (*Task) GetNormalTaskLength

func (t *Task) GetNormalTaskLength() (int64, error)

func (*Task) GetNormalTaskList

func (t *Task) GetNormalTaskList() ([]string, error)

func (*Task) GetSuccessTaskLength

func (t *Task) GetSuccessTaskLength() (int64, error)

func (*Task) GetSuccessTaskList

func (t *Task) GetSuccessTaskList() ([]string, error)

func (*Task) PutFailTask

func (t *Task) PutFailTask(taskId string, data Map) error

func (*Task) PutNormalTask

func (t *Task) PutNormalTask(taskId string, data Map) error

func (*Task) PutSuccessTask

func (t *Task) PutSuccessTask(taskId string, data Map) error

func (*Task) TakeFailTask

func (t *Task) TakeFailTask() (Map, error)

func (*Task) TakeNormalTask

func (t *Task) TakeNormalTask() (Map, error)

func (*Task) TakeSuccessTask

func (t *Task) TakeSuccessTask() (Map, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL