pool

package

v1.16.2 Latest Latest Go to latest Published: Jul 10, 2026 License: Apache-2.0 Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Pool[T any, K comparable] struct {
	// contains filtered or unexported fields
}

func New[T any, K comparable](new func(key K) Runner[T]) *Pool[T, K]

func (p *Pool[T, K]) Close() error

func (p *Pool[T, K]) Get(key K) Runner[T]

func (p *Pool[T, K]) Keys() []K

func (p *Pool[T, K]) LastWrite(key K) time.Time

func (p *Pool[T, K]) Remove(key K)

type Runner[T any] interface {
	Run()
	Push(t T)
	Close() error
}