チャンネルまたはsync.Condを使用して条件を待つ

Question

私は特定の条件を待つことを試みています。これがどのように最もうまくいったかについてアドバイスをしたいと思います。私はview変数に読み込まれたファイルを、更新しています、ゴルーチンで

type view struct { 
    timeFrameReached bool 
    Rows []*sitRow 
} 

：私はこの（簡体字）のように見える構造体を持っています。行数が増加し、timeFrameReachedは最終的にtrueになります。

他の場所で、私は本当のことを、以下の条件を待ちたい：

view.timeFrameReached == true || len(view.Rows) >= numRows 

私はチャンネルを習得しようとしていますし、Goの条件変数がどのように働くか、と私は最善の解決策はここにあるものを知っていただきたいと思います。理論的には、私はこれのような簡単なことをすることができます：

しかし、それは明らかにナイーブな解決策です。 numRowsという値はHTTPリクエストから来るので、条件メソッドは難しいようです。ゴルーチンは、条件をブロードキャストするタイミングを知らないため、探している行の数が分からないためです。

Answer 1

私はこれを条件変数で行うと思います。ウェイターがチェックしたい条件が真であるときに、それが真実であるとき（すなわち、チェックされているものが変更されたとき）にのみSignalが実行されるべきではないという概念ではない。

は

これを行うための通常のパターンは次のとおりです。次に

mutex.Lock() 
for { 
    view = getView() 
    if view.timeFrameReached == true || len(view.Rows) >= numRows { 
     break 
    } 
    cond.Wait(&mutex) 
} 
// Do stuff with view 
mutex.Unlock() 

、コードにviewが変更された場合：明らか

mutex.Lock() 
// Change view 
cond.Signal() // or cond.Broadcast() 
mutex.Unlock() 

、私はあなたのプログラムがどのように機能するかを知らなくても、これを書いています、あなたはいくつかの変更を加えなければならないかもしれません。

あなたは、信号を送るためにチャンネルを送信し、待つためにチャンネルから受信しようとすることで、何か似たようなことをすることができますが、それはもっと複雑です。また、複数のゴルーチンが待ち受けている場合は、cond.Broadcastを使って起床するようにすべての信号を送ることができます。

Answer 2

私はチャネルを介して必要な数の行と建物のゴルーチンビューは、メインスレッドが特定の数の行を要求しているかどうかを確認するために非ブロック受信を行います。そうであれば、条件が満たされたことを示すメッセージを返します。行の特定の数が必要な場合ここ

if numRows > len(viewFile.View.Rows) && !viewFile.View.TimeFrameReached { 
    // Send the required number of rows 
    rows <- numRows 
    // Wait for the prefetch loop to signal that the view file is ready 
    <-rows // Discard the response value and move on 
    view = getView() 
} 

ゴルーチンチェック：ここ

main関数は、行の数を要求します。そうであれば、準備完了時に肯定的な信号で応答する。その信号の値は重要ではありません。

select { 
    case numRows := <-rows: 
     if len(viewFile.View.Rows) >= numRows || viewFile.View.TimeFrameReached { 
      rows <- 1 
     } 
    default: 
}