package processor

import (
	. "gitee.com/kristas/booting-go/framework/core/bean"
	"gitee.com/kristas/booting-go/framework/core/bean_factory"
	"gitee.com/kristas/booting-go/framework/core/configure"
	"sync"
)

type Processor interface {
	Filter(bean Bean) bool
	Do(bean Bean)
}

func Run(processor Processor, bean ...Bean) {
	var wg sync.WaitGroup
	bean_factory.Autowired(processor)
	configure.InjectStructure(processor)
	wg.Add(len(bean))
	for i := range bean {
		go func(i int) {
			b := bean[i]
			if processor.Filter(b) {
				processor.Do(b)
			}
			wg.Done()
		}(i)
	}
	wg.Wait()
}