channel/unlimited_runner.go

20 lines
417 B
Go

package channel
// UnlimitedRunner is a Runner which runs each method
// in its own routine
type UnlimitedRunner struct {
}
var _ Runner = &UnlimitedRunner{}
// NewUnlimitedRunner returns a new LimitedRunner with the given amount
// of allowed routines
func NewUnlimitedRunner() *UnlimitedRunner {
return &UnlimitedRunner{}
}
// Run always returns immediately
func (r *UnlimitedRunner) Run(f func()) {
go f()
}