shredder

package

v0.7.4 Latest Latest Go to latest Published: Oct 25, 2025 License: UNKNOWN not legal advice Imports: 0 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

func Run(f func(*Thread), threads ...*JoinedThread)

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

func R(t *Thread) *JoinedThread

func Ri(t *Thread) *JoinedThread

func W(t *Thread) *JoinedThread

func Wi(t *Thread) *JoinedThread

func Ws(t *Thread) *JoinedThread

func Wsi(t *Thread) *JoinedThread

type OnPanic interface {
	OnPanic(error)
}

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

func NewPool(limit int) *Pool

func (p *Pool) Spawner(op OnPanic) *Spawner

func (p *Pool) Tune(limit int)

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

func (s *Spawner) Go(f func()) bool

func (s *Spawner) Kill()

func (s *Spawner) NewThead() *Thread

func (s *Spawner) Spawn(run func(), result func(error)) bool

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

func (t *Thread) IsDone() bool

func (t *Thread) Kill(after func()) bool

func (t *Thread) Killed() bool