channel

    0

    1答えて

    私が複数の場合に、このようなselectを使用しています: for { select { case data:= <- highFreqChan: // do something: case <- time.After(time.Second * 5): // send some heartbeat like data... } }

    1

    1答えて

    私の目的は、共通フォーマットを共有する1つまたは複数のcsvファイルを読み込み、csvデータのパーティション列に基づいて別々のファイルに書き込むことです。最後の列がパーティションで、そのデータがソートされておらず、特定のパーティションが複数のファイルに存在することを許可してください。一つのファイルの例: fsdio,abc,def,2017,11,06,01 1sdf9,abc,def,2017

    0

    1答えて

    私はユーザーがファイルをアップロードし、処理のためにキューに入れることができるアプリを書いています。私のアプローチは、アップロードされたファイルを処理するためのゴルーチンを作成し、チャンネルを使って新しいファイルが処理できる状態になったことを知らせることです。 は、基本的には、処理ゴルーチンがこれを行います。これは非であることを select { case signalChan <- true:

    0

    1答えて

    Channelは、参加者が非公開および機密トランザクションを確実に行うためのメカニズムです。参加者が複数のチャンネルのメンバーでないような方法でチャンネルが作成された場合、「ファブリック」(または世界の)状態の意味は何ですか?このようなシナリオは存在しますか?

    -2

    2答えて

    official code example func sum(s []int, c chan int) { sum := 0 for _, v := range s { sum += v } c <- sum // send sum to c } func main() { s := []int{7, 2, 8, -9, 4, 0

    0

    2答えて

    このような状況を考慮してください。 1つのメインgoroutineと10個の補助 のゴルーチンがあります。すべてのユーザーはchannelにアクセスできます。メインチャンネルは1000の番号をこのチャンネルに送信し、子機の番号はこのチャンネルから読み取ります。 各従属ゴルーチンが100個の数字を正確に読み取ることが保証されているか、またはこの金額はいくつかのゴルーチンが99個の数字と101個の数字

    0

    1答えて

    私はすぐに録音して再生しようとしています。私はそれぞれ左チャンネルと右チャンネルで演奏する必要があります。 AudioUnitを使用して1つのチャンネルで録音して再生できます。しかし、2つのバッファを使って2つのチャンネルを制御しようとすると、両方ともミュート状態になります。ここで私は書式を設定方法は次のとおりです。 var audioFormat = AudioStreamBasicDescri

    0

    1答えて

    は、次の行は、キューチャネルを閉じるようだ: d.Ack() 誰もがd.Ack()がために、実際に何であるかを説明してもらえますか?キューチャネルを閉鎖するのはなぜですか?

    0

    1答えて

    私はいくつかのチャネル出力をgoで多重化するソリューションを探しています。 私は、単一のチャンネルに送信するio.Readerからの読み取りであるデータソースを持っています。反対側で私はチャネルから読み取るwebsocket要求ハンドラがあります。今度は、2つのクライアントがwebsocket接続を作成します。両方とも同じチャネルから読み取りますが、それぞれがメッセージの一部を取得するだけです。

    1

    1答えて

    私はすべてのファイルをフォルダリンクからスキャンし、彼のサイズと彼の名前に基づいて正規表現で自分のサイズで "トップ10"を作るようにしようとしています。ファイル。コンテンツでは、私はgoroutinesでチャンネルを作っていますが、私のgoroutinesがロックされるたびに理由を理解できません。ここで package main import ( "flag" "fmt"