-
-
Save include/4039bcab377e90ecf601 to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
ls -la | |
echo "hello" | |
tree | |
adb devices | |
adb wait-for-device #example of a long running task |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
package main | |
import ( | |
"bufio" | |
"fmt" | |
"gopkg.in/pipe.v2" | |
"os" | |
"strings" | |
"time" | |
) | |
func readLines(path string) []string { | |
inFile, _ := os.Open(path) | |
defer inFile.Close() | |
scanner := bufio.NewScanner(inFile) | |
scanner.Split(bufio.ScanLines) | |
var lines []string | |
for scanner.Scan() { | |
lines = append(lines, scanner.Text()) | |
} | |
return lines | |
} | |
func parseScript(path string) map[string][]string { | |
cmds := make(map[string][]string) | |
for _, line := range readLines(path) { | |
args := strings.Fields(line) | |
cmds[args[0]] = args[1:] | |
} | |
return cmds | |
} | |
func execScript(script map[string][]string, status chan string, quit chan bool) { | |
s := pipe.NewState(nil, nil) | |
go func() { | |
for name, args := range script { | |
p := pipe.Line(pipe.Exec(name, args...), pipe.WriteFile("console.txt", 0777)) | |
p(s) | |
cmdline := name + " " + fmt.Sprintf("%s", args) | |
s.RunTasks() | |
status <- cmdline | |
} | |
}() | |
<-quit | |
s.Kill() | |
} | |
/*Working with the assumption that the script is simply a sequence of commands*/ | |
func main() { | |
script := parseScript("script.sh") | |
status := make(chan string) | |
quit := make(chan bool) | |
go execScript(script, status, quit) | |
for i := 0; i < len(script); i++ { | |
select { | |
case s := <-status: | |
fmt.Printf("task done: %v\n", s) | |
case <-time.After(time.Second * 10): | |
fmt.Println("timed out") | |
quit <- true | |
} | |
} | |
} |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment