Futureパターンが使われているOSSを見てみた

package main

func readFile(path string) chan string {
  // ファイルを読み込み、その結果を返すFutureを返す
  promise := make(chan string)

	// readFile とは別のゴルーチンでファイルを読み出す
  go func() {
    content, err := os.ReadFile(path)
    if err != nil {
      fmt.Printf("read error %s\n", err.Error())
      close(promise)
    } else {
      // 約束を果たした
      promise <- string(content)
    }
  }()
  return promise
}
 
func printFunc(futureSource chan string) chan []string {
  // 文字列中の関数一覧を返すFutureを返す
  promise := make(chan []string)

	// printFunc とは別のゴルーチンで文字列操作する
  go func() {
    var result []string

		// futureSource は readFile で読みだしたファイルの中身です
		//
		// readFile(ファイル読み込み)が完了して、 futureSource(=promise) に
		// 中身が送信されるまでこの処理は実行されません
    for _, line := range strings.Split(<-futureSource, "\n") {
      if strings.HasPrefix(line, "func ") {
        result = append(result, line)
      }
    }
    // 約束を果たした
    promise <- result
  }()
  return promise
}

func main() {
  futureSource := readFile("future_promise.go")

	// 一見、 readFile が実行されたあとに、すぐ printFunc が実行されるように見えます
	// しかし、 printFunc の引数(futureSource)がチャネルになっているので、
	// futureSourceが値を受信するまで関数内で、futureSource を使うことができない
	//
	// よって関数内で実行待ちが発生します
  futureFuncs := printFunc(futureSource)

	// チャネル(futureFuncs)を受信するまでブロック
  fmt.Println(strings.Join(<-futureFuncs, "\n"))
}