qsants

var Module = fx.Options(
	fx.Provide(
		fx.Annotate(
			func(threadCount int, configs *ants.Options, logger *zap.Logger, lc fx.Lifecycle) (*ants.Pool, error) {
				if configs == nil {
					return nil, nil
				}
				p, _ := newPool(threadCount, ants.WithOptions(*configs))

				lc.Append(fx.Hook{
					OnStart: func(ctx context.Context) error {
						if logger != nil {
							logger.Info("Thread pool", zap.Int("Number of threads", threadCount))
						} else {
							log.Printf("Thread pool count=%v\n", threadCount)
						}
						return nil
					},
					OnStop: func(ctx context.Context) error {
						if logger != nil {
							logger.Info("Stopping thread pool")
						} else {
							log.Println("Stopping thread pool")
						}
						if !p.IsClosed() {
							p.Release()
						}
						defer ants.Release()
						return nil
					},
				})
				return p, nil
			},
			fx.ParamTags(
				`name:"threadCount" optional:"true"`,
				`optional:"true"`,
				`optional:"true"`,
			),
		),
	),
)