runner

Overview ¶

Package runner runs distinct commands in parallel goroutines while queueing indistinct commands so they're never run twice at the same time (but all get run eventually).

Simply send your command to runner and let it do the rest!

Example usage:

  package main

  import "github.com/modcloth/queued-command-runner"

  import (
  	"fmt"
  	"os"
  	"os/exec"
  )

  func main() {
  	fmt.Println("Running a command now.")

  	pwd := os.Getenv("PWD")

	ls := exec.Command("ls", "-la", pwd)
	ls.Stdout = os.Stdout
	ls.Stderr = os.Stderr
	cmd := &runner.Command{
		Cmd: ls,
	}

	runner.Run(cmd)

  	WaitOnRunner:
  	for {
  		select {
  		case <-runner.Done:
  			break WaitOnRunner
		case err := <-runner.Errors:
			fmt.Printf("Uh oh, got an error: %q\n", err)
  		}
  	}

  	os.Exit(0)
  }