channel

1熱

1答えて

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

0熱

1答えて

ワーカーのゴルーチンのアイテムをキューに入れる正しい方法は？

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

0熱

1答えて

Hyperledgerネットワークの非同期チャネル

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 - スウィフトの左チャンネルと右チャンネルの出力を制御します

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

0熱

1答えて

のRabbitMQ：私はRabbitMQの</p> <p>とRPCについてこの<a href="https://www.rabbitmq.com/tutorials/tutorial-six-go.html" rel="nofollow noreferrer">tutorial</a>を読んでいますd.Ack（）近いチャネル

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

0熱

1答えて

goでチャネル出力を多重化する方法

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

1熱

1答えて

Golang Goroutineエラー "すべてのゴルーチンが眠っています - デッドロックです！"

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

0熱

1答えて

無視された低速ケースを選択しますか？

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