Source File
	example_fan_out_in.go

Belonging Package
	github.com/pancsta/asyncmachine-go/examples/fan_out_in

package main

import (
	"context"
	"time"

	"github.com/joho/godotenv"

	amhelp "github.com/pancsta/asyncmachine-go/pkg/helpers"
	am "github.com/pancsta/asyncmachine-go/pkg/machine"
	amxhelp "github.com/pancsta/asyncmachine-go/pkg/x/helpers"
)

func init() {
	// load .env
	_ = godotenv.Load()

	// am-dbg is required for debugging, go run it
	// go run github.com/pancsta/asyncmachine-go/tools/cmd/am-dbg@latest
	amhelp.EnableDebugging(false)
	amhelp.SetEnvLogLevel(am.LogChanges)
}

func main() {
	ctx := context.Background()

	states := am.Schema{
		// task start state
		"Task": {Require: am.S{"Start"}},
		// task done state
		"TaskDone": {},

		// rest

		"Start": {},
		"Ready": {
			Auto:    true,
			Require: am.S{"TaskDone"},
		},
		"Healthcheck": {Multi: true},
	}
	names := am.S{"Start", "Task", "TaskDone", "Ready", "Healthcheck", am.StateException}

	// init state machine
	mach, err := am.NewCommon(ctx, "fan", states, names, &am.ExceptionHandler{}, nil, &am.Opts{
		LogLevel: am.LogOps,
	})
	if err != nil {
		panic(err)
	}
	amhelp.MachDebugEnv(mach)

	// define a task func
	fn := func(num int, state, stateDone string) {
		ctx := mach.NewStateCtx(state)
		go func() {
			if ctx.Err() != nil {
				return // expired
			}
			amhelp.Wait(ctx, time.Second)
			if ctx.Err() != nil {
				return // expired
			}
			mach.Add1(stateDone, nil)
		}()
	}

	// create task states
	// 10 tasks, 3 running concurrently
	_, err = amxhelp.FanOutIn(mach, "Task", 15, 3, fn)
	if err != nil {
		panic(err)
	}

	// start and wait
	mach.Add(am.S{"Start", "Task"}, nil)
	<-mach.When1("Ready", nil)

	// end
	println("done")

	// debug
	time.Sleep(time.Second)
}

The pages are generated with Golds v0.8.2. (GOOS=linux GOARCH=amd64)
Golds is a Go 101 project developed by Tapir Liu.
PR and bug reports are welcome and can be submitted to the issue list.
Please follow @zigo_101 (reachable from the left QR code) to get the latest news of Golds.