Merge pull request #360 from devlights/devlights/os-exec-stdinpipe-stdoutpipe-354

Add example of (*Cmd).StdinPipe/StdoutPipe/StderrPipe

Author: devlights

internal/examples/basic/cmdexec/README.md

@@ -8,3 +8,4 @@
 |oneshotwithstderr.go|cmdexec\_oneshot\_with\_stderr|コマンドを一発実行して結果を取得するサンプルです。(標準エラー出力も含む)|
 |stdinouterr.go|cmdexec\_stdinouterr|標準入力・標準出力・標準エラー出力を指定してコマンドを実行するサンプルです|
 |withcontext.go|cmdexec\_withcontext|コマンドを context.Context 付きで実行するサンプルです|
+|pipe.go|cmdexec\_pipe|(*Cmd).StdinPipe,StdoutPipe,StderrPipeのサンプルです|

internal/examples/basic/cmdexec/examples.go

@@ -19,4 +19,5 @@ func (r *register) Regist(m mappings.ExampleMapping) {
 	m["cmdexec_oneshot_with_stderr"] = OneShotWithStderr
 	m["cmdexec_stdinouterr"] = Stdinouterr
 	m["cmdexec_withcontext"] = WithContext
+	m["cmdexec_pipe"] = Pipe
 }

internal/examples/basic/cmdexec/pipe.go

@@ -0,0 +1,94 @@
+package cmdexec
+
+import (
+	"bufio"
+	"errors"
+	"fmt"
+	"io"
+	"os/exec"
+	"runtime"
+)
+
+// Pipe は、 (*Cmd).StdinPipe,StdoutPipe,StderrPipeのサンプルです。
+//
+// REFERENCES:
+//   - https://golang.org/pkg/os/exec/#example_Cmd_StdinPipe
+func Pipe() error {
+	if runtime.GOOS == "windows" {
+		return errors.New("this example cannot run on Windows, sorry")
+	}
+
+	const (
+		Shell = "/bin/bash"
+	)
+
+	var (
+		cmd     *exec.Cmd      // コマンド
+		fd0Pipe io.WriteCloser // 標準入力のパイプ
+		fd1Pipe io.ReadCloser  // 標準出力のパイプ
+		fd2Pipe io.ReadCloser  // 標準エラー出力のパイプ
+	)
+
+	// コマンド構築
+	cmd = exec.Command(Shell, "-c", "tr a-z A-Z | sort; echo ...done... 1>&2")
+
+	//
+	// パイプを取得
+	//   パイプを扱う場合は、それぞれを非同期で処理する必要がある。
+	//
+	fd0Pipe, _ = cmd.StdinPipe()
+	fd1Pipe, _ = cmd.StdoutPipe()
+	fd2Pipe, _ = cmd.StderrPipe()
+
+	//
+	// コマンド実行
+	//   StdoutPipe または StderrPipe を利用する場合
+	//   (*Cmd).Run() でコマンドを実行しない。
+	//   (*Cmd).Start() で実行して (*Cmd).Wait() で待つようにする。
+	//
+	if err := cmd.Start(); err != nil {
+		return err
+	}
+
+	// 標準入力のハンドリング
+	go func() {
+		//
+		// 入力が完了したことを示すために明示的に Close する
+		//
+		defer fd0Pipe.Close()
+
+		io.WriteString(fd0Pipe, "python\n")
+		io.WriteString(fd0Pipe, "csharp\n")
+		io.WriteString(fd0Pipe, "golang\n")
+		io.WriteString(fd0Pipe, "java\n")
+	}()
+
+	// 標準出力のハンドリング
+	go func() {
+		//
+		// 標準出力のパイプは (*Cmd).Wait() の呼び出しにて Close されるので
+		// 通常呼ぶ必要はない。
+		//
+		scanner := bufio.NewScanner(fd1Pipe)
+		for scanner.Scan() {
+			fmt.Println(scanner.Text())
+		}
+	}()
+
+	// 標準エラー出力のハンドリング
+	go func() {
+		//
+		// 標準エラー出力のパイプは (*Cmd).Wait() の呼び出しにて Close されるので
+		// 通常呼ぶ必要はない。
+		//
+		b, _ := io.ReadAll(fd2Pipe)
+		fmt.Println(string(b))
+	}()
+
+	// コマンド終了待ち
+	if err := cmd.Wait(); err != nil {
+		return err
+	}
+
+	return nil
+}