runner

package

v0.2.23 Latest Latest Go to latest Published: Mar 6, 2019 License: MIT Imports: 2 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Finish func()

type IRunner interface {
	Wait() error
	Stop()
}

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

func Go(f func(s StopChan, f Finish)) (r *Runner)

Go starts the given function in a goroutine and adds the ability to stop it gracefully.

In your runner listen for the stop channel to be closed, then call finish() to stop the runner.

Example:

task := Go(func(stop StopChan, finish Finish) {
	for {
		select {
		case _, ok := <-stop:
			if !ok {
				finish()
				return
			}
		}
	}
}

func (r *Runner) Stop()

Stop will signal the runner to finish the given goroutine. It is not possible to reuse a stopped runner

func (r *Runner) Wait() (err error)

Wait will wait for 2 seconds for the runner to stop otherwise it returns an error

type StopChan <-chan struct{}