parallel.go

package main

import (
	"fmt"
	"sync"
	"sync/atomic"
)

func main() {
	result := MultiJudge(4, []JudgeFunc{
		func(a any) bool {
			fmt.Println("judge 1 called")
			return a.(int) == 1
		},
		func(a any) bool {
			fmt.Println("judge 2 called")
			return a.(int) == 2
		},
		func(a any) bool {
			fmt.Println("judge 3 called")
			return a.(int) == 3
		},
		func(a any) bool {
			fmt.Println("judge 4 called")
			return a.(int) == 4
		},
	})

	fmt.Println("multiJudge result", result)
}

type JudgeFunc func(any) bool

func MultiJudge(value any, judgeFuncs []JudgeFunc) bool {
	var result int32
	wg := sync.WaitGroup{}

	for _, judgeFunc := range judgeFuncs {
		wg.Add(1)
		judgeFunc := judgeFunc
		go func() {
			defer wg.Done()
			if atomic.LoadInt32(&result) == 0 {
				if judgeFunc(value) {
					atomic.StoreInt32(&result, 1)
				}
			}
		}()
	}

	wg.Wait()

	return result != 0
}