Weight Task

Introduction

This Go-based project provides a system for managing and executing tasks based on their weight. Specifically, it concurrently executes a collection of tasks and returns the result of the one with the highest weight.

How It Works

In the context of the Weight Task Processor, a "Task" is defined as any operation with a defined Weight and an Execute function. Here's what these mean:

Weight: An integer indicating relative importance. Higher numbers indicate higher weight.
PerformTask: The function that performs the given task.

Task processing involves two major steps:

Adding Tasks: Tasks to be executed are added into the Weight Task Processor using the AddTask method. Each task is an instance of a struct that implements the Task interface.
Processing Tasks: The ProcessTasks function executes all tasks concurrently and retrieves the result from the task with the highest weight. If multiple tasks share the same highest weight, it will return the first result.

How to Use

Here's a basic example of how to use the Weight Task Processor:

Implement the Task interface in your task struct.
Initiate a new instance of NewTaskController via NewTaskController().
Add tasks into the Tasker via AddTask.
Call the ProcessTasks method to begin executing tasks. This will return the result of the highest weight task that is valid. If no tasks are valid, it will return an error.

package main

import (
	"context"
	"fmt"
	"time"

	"github.com/icpd/weightask"
)

type MyTask struct {
	weight int
	v      string
}

func (t MyTask) Weight() int {
	return t.weight
}

func (t MyTask) PerformTask() (any, error) {
	time.Sleep(time.Second * time.Duration(t.weight))
	return t.v, nil
}

func main() {
	tc := weightask.NewTaskController()

	// add tasks
	tc.AddTask(&MyTask{weight: 1, v: "task 1"})
	tc.AddTask(&MyTask{weight: 2, v: "task 2"})
	tc.AddTask(&MyTask{weight: 3, v: "task 3"})

	// process tasks
	res, err := tc.ProcessTasks(context.Background())
	if err != nil {
		fmt.Println("Error:", err)
		return
	}

	fmt.Println("Result:", res) // Result: task 3
}