workerpool

Documentation

Index

• type QueuedConfig
• type QueuedPool
  • func NewQueued(config QueuedConfig) *QueuedPool
  • func NewQueuedWithLogger(config QueuedConfig, logger *slog.Logger) *QueuedPool
  • func (p *QueuedPool) Pending() int
  • func (p *QueuedPool) QueueSize() int
  • func (p *QueuedPool) StopAndWait()
  • func (p *QueuedPool) StopAndWaitContext(ctx context.Context) error
  • func (p *QueuedPool) SubmitWait(task func()) bool
  • func (p *QueuedPool) TrySubmit(task func()) bool
  • func (p *QueuedPool) Workers() int

Types

type QueuedConfig

type QueuedConfig struct {
	Workers   int
	QueueSize int
}

type QueuedPool

type QueuedPool struct {
	// contains filtered or unexported fields
}

func NewQueued

func NewQueued(config QueuedConfig) *QueuedPool

func NewQueuedWithLogger

func NewQueuedWithLogger(config QueuedConfig, logger *slog.Logger) *QueuedPool

NewQueuedWithLogger는 panic recover 로그에 사용할 logger를 주입한다. logger가 nil이면 slog.Default()를 사용한다.

func (*QueuedPool) Pending

func (p *QueuedPool) Pending() int

func (*QueuedPool) QueueSize

func (p *QueuedPool) QueueSize() int

func (*QueuedPool) StopAndWait

func (p *QueuedPool) StopAndWait()

func (*QueuedPool) StopAndWaitContext

func (p *QueuedPool) StopAndWaitContext(ctx context.Context) error

func (*QueuedPool) SubmitWait

func (p *QueuedPool) SubmitWait(task func()) bool

func (*QueuedPool) TrySubmit

func (p *QueuedPool) TrySubmit(task func()) bool

func (*QueuedPool) Workers

func (p *QueuedPool) Workers() int