Go のジェネレーター同時実行パターン: 包括的なガイド

⚠️ このシリーズをどのように進めていきますか?

1.すべての例を実行: コードを読むだけではありません。入力して実行し、動作を観察してください。
2.実験と破壊: スリープを削除して何が起こるか確認し、チャネル バッファー サイズを変更し、ゴルーチン数を変更します。
物を壊すことで、その仕組みがわかる
3.動作に関する理由: 変更されたコードを実行する前に、結果を予測してみてください。予期せぬ動作が見られた場合は、立ち止まってその理由を考えてください。解説に挑戦してください。
4.メンタル モデルの構築: 各ビジュアライゼーションはコンセプトを表します。変更されたコード用に独自の図を描いてみてください。

前回の投稿では、Go の並行性の構成要素であるゴルーチンとチャネルの基本について説明しました。ここをお読みください:

Golang でのゴルーチンとチャネルの理解と視覚化

スーヴィク・カル・マハパトラ・12月20日

＃行く ＃プログラミング ＃学ぶ ＃チュートリアル

ここで、これらのプリミティブがどのように組み合わされて、現実世界の問題を解決する強力なパターンを形成するかを見てみましょう。

この投稿では、ジェネレーター パターン について説明し、視覚化してみます。プロセス全体を通じて実際に作業を進めていきますので、準備を整えましょう。

ジェネレーターパターン

ジェネレーターは、必要なときにいつでも消費できる価値を継続的に生成する噴水のようなものです。

Go では、これは値のストリームを生成し、チャネルを通じて送信する関数であり、プログラムの他の部分がこれらの値をオンデマンドで受信できるようにします。

例を見てみましょう:

// generateNumbers creates a generator that produces numbers from 1 to max
func generateNumbers(max int) chan int {
    // Create a channel to send numbers
    out := make(chan int)

    // Launch a goroutine to generate numbers
    go func() {
        // Important: Always close the channel when done
        defer close(out)

        for i := 1; i 



<p>この例では、ジェネレーター関数は 3 つの重要なことを実行します。</p>

<ol>
<li>値を送信するチャネルを作成します</li>
<li>値を生成するゴルーチンを起動します</li>
<li>消費者が使用できるチャネルをすぐに返します</li>
</ol>

<h3>
  
  
  ジェネレーターを使用する理由
</h3>

<ol>
<li>価値の生産と消費を分離する</li>
<li>オンデマンドで値を生成 (遅延評価)</li>
<li>無限のメモリを消費せずに無限のシーケンスを表現できます</li>
<li>値の同時生成と消費を許可します</li>
</ol>

<h3>
  
  
  実際の使用例
</h3>

<p>大きなファイルを 1 行ずつ読み取る:<br>
</p>

<pre class="brush:php;toolbar:false">func generateLines(filename string) chan string {
    out := make(chan string)
    go func() {
        defer close(out)
        file, err := os.Open(filename)
        if err != nil {
            return
        }
        defer file.Close()

        scanner := bufio.NewScanner(file)
        for scanner.Scan() {
            out 



<p>ここで、<u>何がそんなに特別なの?と考えているかもしれません。データのシーケンスを生成したり、ゴルーチン</u> を使用せずに 1 行ずつ読み取るのと同じことを行うことができます。やりすぎじゃないですか？両方のケースを視覚化してみましょう:</p>

<p><strong>ゴルーチンなし</strong><br>
</p>

<pre class="brush:php;toolbar:false">// Traditional approach
func getNumbers(max int) []int {
    numbers := make([]int, max)
    for i := 1; i 



<p>ここでは、処理を開始する前に、すべての準備が整うまで待つ必要があります。</p>

<p><strong>ゴルーチンを使用する</strong><br>
</p>

<pre class="brush:php;toolbar:false">// Generator approach
func generateNumbers(max int) chan int {
    out := make(chan int)
    go func() {
        defer close(out)
        for i := 1; i 



<p>データの生成中にデータの処理を開始できます。</p>

<p><img src="/static/imghwm/default1.png" data-src="https://img.php.cn/upload/article/000/000/000/173594261452189.jpg?x-oss-process=image/resize,p_40" class="lazy" alt="Generator Concurrency Pattern in Go: A Comprehensive Guide"></p>

<h3>
  
  
  ジェネレーター パターンの主な利点:
</h3>

<ol>
<li><p><strong>ノンブロッキング実行</strong>: 生成と処理は同時に行われます</p></li>
<li><p><strong>メモリ効率</strong>: 一度に 1 つの値を生成して処理できるため、すぐにメモリに保存する必要はありません</p></li>
<li><p><strong>無限シーケンス</strong>: メモリの問題なく無限シーケンスを生成できます</p></li>
<li><p><strong>バックプレッシャー処理</strong>: コンシューマが遅い場合、ジェネレータは自然に (チャネル ブロックにより) 速度を落とし、メモリの過負荷を防ぎます。<br>
</p></li>
</ol>

<pre class="brush:php;toolbar:false">// generateNumbers creates a generator that produces numbers from 1 to max
func generateNumbers(max int) chan int {
    // Create a channel to send numbers
    out := make(chan int)

    // Launch a goroutine to generate numbers
    go func() {
        // Important: Always close the channel when done
        defer close(out)

        for i := 1; i 



<h3>
  
  
  よくある落とし穴と解決策
</h3>

<ol>
<li>チャンネルを閉じ忘れる
</li>
</ol>

<pre class="brush:php;toolbar:false">func generateLines(filename string) chan string {
    out := make(chan string)
    go func() {
        defer close(out)
        file, err := os.Open(filename)
        if err != nil {
            return
        }
        defer file.Close()

        scanner := bufio.NewScanner(file)
        for scanner.Scan() {
            out 



<ol>
<li>エラーを処理しない
</li>
</ol>

<pre class="brush:php;toolbar:false">// Traditional approach
func getNumbers(max int) []int {
    numbers := make([]int, max)
    for i := 1; i 



<ol>
<li>リソース リーク: リソース (ファイルなど) でジェネレーターを使用する場合は、適切なクリーンアップを確認してください。
</li>
</ol>

<pre class="brush:php;toolbar:false">// Generator approach
func generateNumbers(max int) chan int {
    out := make(chan int)
    go func() {
        defer close(out)
        for i := 1; i 



<p>ジェネレータ パターンについては以上です。次は <strong>パイプライン同時実行パターン</strong> です。 Golang の同時実行性に関する概念を明確にするために、ご期待ください。</p>

<p>何か見逃したでしょうか？質問がありますか?何か面白いことを共有したいですか？すべてのコメントを歓迎します。</p>


          

            
  

            
        

以上がGo のジェネレーター同時実行パターン: 包括的なガイドの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。