Asynchrone Aufgabenorchestrierung via Context-AfterFunc-Registrierung

package main
 
import (
	"context"
	"fmt"
	"sync"
	"time"
)
 
func executeOrchestratedTask(ctx context.Context) error {
	var wg sync.WaitGroup
	wg.Add(1)
 
	stopFunc := context.AfterFunc(ctx, func() {
		fmt.Println("Context cancelled: Aborting background worker...")
		wg.Done()
	})
 
	go func() {
		defer wg.Done()
		select {
		case <-time.After(100 * time.Millisecond):
			if stopFunc() {
				fmt.Println("Task completed successfully before context deadline.")
			}
		case <-ctx.Done():
			return
		}
	}()
 
	wg.Wait()
	return ctx.Err()
}
 
func main() {
	ctx, cancel := context.WithTimeout(context.Background(), 50*time.Millisecond)
	defer cancel()
	_ = executeOrchestratedTask(ctx)
}