shredder

package

v0.3.0 Latest Latest Go to latest Published: Aug 20, 2025 License: UNKNOWN not legal advice Imports: 0 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

This section is empty.

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

func R(t *Thread) *JoinedThread

func W(t *Thread) *JoinedThread

func WS(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

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

func (th *Thread) Read(f func(*Thread), joined ...*JoinedThread)

func (th *Thread) ReadInstant(f func(*Thread), joined ...*JoinedThread)

func (th *Thread) Write(f func(*Thread), joined ...*JoinedThread)

func (th *Thread) WriteInstant(f func(*Thread), joined ...*JoinedThread)

func (th *Thread) WriteInstantStarving(f func(*Thread), joined ...*JoinedThread)

func (th *Thread) WriteStarving(f func(*Thread), joined ...*JoinedThread)