Elixir-Style Actors in Go :: Random Bits of Wisdom
My foray into Elixir brought forward many more similarities between it and Go, than I originally expected. One of them is how both handle concurrency. With respect to that, creating Elixir-style stateful actors in Go is surprisingly easy. Answering the question, whether one needs them, or can make use of them, I’d leave to the user. If you approach me back saying that the same thing can be achieve
Go言語での複数チャネルからのメッセージ受信 - ryochack.blog
Goではgoroutineを使うことで並行処理をとても簡単に実行できるが、複数goroutineとの同期が難しい。 そこで、複数走らせたgoroutineのメッセージを用いた同期方法について考えてみた。 以下のように、複数のチャネルからのメッセージを受信する必要がある時、どうやって各goroutineからのメッセージを、同時に、最後まで、受信すればいいか？ func f(msg string, n int) chan string { ch := make(chan string) go func() { for i:=0; i<n; i++ { ch <- msg + " please!" } close(ch) }() return ch } func main() { ch1 := f("beer", 4) ch2 := f("juice", 2) ch3 := f("water",
Concurrency is not Parallelism
Concurrency is not Parallelism Waza Jan 11, 2012 Rob Pike Video This talk was presented at Heroku's Waza conference in January 2012. Watch the talk on Vimeo 2 The modern world is parallel Multicore. Networks. Clouds of CPUs. Loads of users. Our technology should help. That's where concurrency comes in. 3 Go supports concurrency Go provides: concurrent execution (goroutines) synchronization and mes
Coding in the context era
This document summarizes a talk about using context.Context for concurrency in Go programming. It recommends using context.Context to pass cancellation and deadline information between goroutines instead of manually synchronizing access to shared resources with mutexes. Context makes code cleaner by making cancellation explicit and avoiding ambiguous APIs. It provides examples of running multiple
Profiling and optimizing Go web applications - Artem Krylysov
Go has a powerful built-in profiler that supports CPU, memory, goroutine and block (contention) profiling. Enabling the profiler # Go provides a low-level profiling API runtime/pprof, but if you are developing a long-running service, it's more convenient to work with a high-level net/http/pprof package. All you need to enable the profiler is to import net/http/pprof and it will automatically regis
Golangのcontext.Valueの使い方
Go1.7でcontextパッケージが標準パッケージに入りしいろいろなところで使われるようになってきた．先日リリースされたGo1.8においてもdatabase/sqlパッケージなどでcontextのサポートが入るなどますます重要なパッケージになっている． “Go1.7のcontextパッケージ”で書いたようにcontextは「キャンセルのためのシグナルの受け渡しの標準的なインターフェース」として主に使われる．ある関数やメソッドの第1引数にcontext.Contextが渡せるようになっていればキャンセルを実行したときにその関数は適切に処理を中断しリソースを解放することを期待する．これはパッケージの作者とその利用者との間のある種の契約のようになっている（パッケージ側でgoroutine作るなというパターンもここで効いてくる）． これだけではなくcontext.Contextインターフェースに
sync.ErrGroupで複数のgoroutineを制御する
Golangの並行処理は強力である一方で同期処理を慎重に実装する必要がある．“Go 言語における並行処理の構築部材”にまとめられているようにGolangは様々な方法でそれを実装することができる．実現したいタスクに合わせてこれらを適切に選択する必要がある． この同期処理の機構として新たにgolang.org/x/sync/errgroupというパッケージが登場した．実際に自分のツールで使ってみて便利だったので簡単に紹介する． 使いどころ 時間のかかる1つのタスクを複数のサブタスクとして並行実行しそれらが全て終了するのを待ち合わせる処理（Latch）を書きたい場合にerrgroupは使える．その中でも「1つでもサブタスクでエラーが発生した場合に他のサブタスクを全てを終了しエラーを返したい」（複数のサブタスクが全て正常に終了して初めて1つの処理として完結する）場合が主な使いどころである． 実例
Goオールスターズ2参加レポート #eventdots | DevelopersIO
丹内です。少し前からGolangを勉強しつつブログ記事を書いていました。 夏のAWS関係の仕事が落ち着いたらGolangを改めて勉強しようと思っていた矢先、タイトルのイベントが開催されていたので、参加しました。 イベントサイト Twitterまとめ いまさら聞けないselectのあれこれ buildersconというイベントを準備中 10/22発売のWeb+DB Press (バッファ付き)チャネルはブロックが発生しうる selectにチャネル操作以外を入れるとエラーとして教えてくれる nil channelは読み書きでブロックするので、selectは成功することがない 有効だったchannelを無効にしたり、ある時点から有効にしたりできる timerとfor selectのパターンはタイムアウトに応用可能 doneチャネル: 処理が終わったらループを脱出 1.7からはcontext se
Big Sky :: golang の channel を使ったテクニックあれこれ
golang の channel は他の言語に見ない独特のパラダイムを開発者に提供します。 単純にスレッド間でメッセージングをするだけでもC言語で書けばそこそこの量になったり、慣れていない人であればどう実装すればいいか分からないなんて事もあったと思います。しかし golang の goroutine/channel は、やっている内容の割にとても容易にスレッド間通信やキューイング、処理の受け待ち等を実装できる様になっています。尚、channel をどの様に適用したら良いかについては以下を参照下さい。 Big Sky :: Golang の channel の使い所 golang の特徴と言えば goroutine と channel ですが、その使いどころに悩む人もおられる様です。 goroutine は非同期に実行される処理、channel はその grout... http://mat
golangのチャンネルでセマフォ的なナニカ - okzkメモ
mattnさんのエントリに触発されて、某所で使用したちょっと変わったgolangのチャンネルの使い方をご紹介します。 mattn.kaoriya.net 特定の処理の並列度をある程度までに抑えたい、みたいなコトありますよね？ 例えばCPUヘビーな処理の並列数をたかだかコア数くらいまでに抑えたい、とか。 そんなときはバッファ付きチャンネルを用意しておいて、当該処理の前後でそのチャンネルにwrite/readをすることで、セマフォ的な制御ができます。 以下のようなカンジです。 package main import ( "fmt" "sync" "time" ) var ch chan int = make(chan int, 4) // 並列度を4に制限 func heavyFunc(i int) { ch <- 1 // チャンネルのバッファがイッパイになっていたら、ブロックする defe
Go 言語における並行処理の構築部材 - 詩と創作・思索のひろば
5年前に買った『Java並行処理プログラミング ―その「基盤」と「最新API」を究める―』をようやく読んだ。買った頃には Perl やシンプルな JavaScript ばかり書いていたので並行プログラミングなんてほとんど気にすることがなく、実感がなくて読むのも途中で止まってしまっていた本で、家を掃除しているときに見つけたもの。その後も趣味で Android アプリを書くなど Java に触れる機会はあったけれど、せいぜいが AsyncTask を使うくらいで、マルチスレッドを強く意識してコードを書くこともなかった。 Java並行処理プログラミング ―その「基盤」と「最新API」を究める― 作者: Brian Goetz,Joshua Bloch,Doug Lea出版社/メーカー: ソフトバンククリエイティブ発売日: 2006/11/22メディア: 単行本購入: 30人 クリック: 442回
golangのよくあるtickerのサンプルがイケてない件 - okzkメモ
golangでのtickerのサンプルで以下のようにgoroutine内でrangeを使ってforループを回すのをよく見かけます。 package main import "time" import "fmt" func main() { ticker := time.NewTicker(10 * time.Millisecond) go func() { for t := range ticker.C { fmt.Println("Tick at", t) } }() time.Sleep(35 * time.Millisecond) ticker.Stop() } コレ、以下のようにちょっと変更して実行してみましょう。 package main import "time" import "fmt" func main() { ticker := time.NewTicker(10 *
Go言語の並行性を映像化する | POSTD
Goというプログラミング言語の強みの１つは、 Tony Hoare考案のCSP に基づくビルトインの並行性(Concurrency)です。Goは並行性を念頭にデザインされているため、複雑に並行したパイプラインの構築を可能にしています。でも、それぞれの並行性パターンがどのように見えるものなのか気になったことはありませんか。 もちろん、気になったことはあると思います。恐らくそれぞれ形は違っても、誰もが頭に描いているのではないでしょうか。もし、「1から100までの数字」について聞かれたら、無意識に頭の中で数字のイメージを思い浮かべると思います。例えば、私の場合、自分の前から1から20までがまっすぐに並び、21以降は90度右に曲がり1000以降まで続くイメージが浮かびます。これは多分私が幼稚園の時に教室の壁に沿って数字が貼られていて、ちょうど角に数字の20があったからなのだと思います。別の例えをす
Go Concurrency Patterns
Go Concurrency Patterns Rob Pike Google Video This talk was presented at Google I/O in June 2012. Watch the talk on YouTube 2 Introduction 3 Concurrency features in Go People seemed fascinated by the concurrency features of Go when the language was first announced. Questions: Why is concurrency supported? What is concurrency, anyway? Where does the idea come from? What is it good for? How do I use
High performance servers without the event loop
High performance servers without the event loop OSCON, Portland 21 July 2015 Dave Cheney whoami(1) Sysadmin before Devops Transitioned to Go 5 years ago Work for Canonical contributing to the Go project 2 Who is this presentation for ? The horror! As an admin in a past life, the most stressful times in my career were defined by unsatisfying performance. I got into Go because of its potential to bu
GoのWEBアプリケーション運用について - Qiita
最近GoでWEBアプリケーションを運用するにあたってどこに気をつけているかをメモしました。 WEBサーバ GoでWEBアプリケーションを作る場合、net/httpパッケージを使うことになります。 Go製のWEBフレームワークを使用する場合であっても、HTTPリクエストの処理部分はnet/httpを使用していると思います。 GoでWEBアプリケーションを書いた場合、すべてのリクエストをGoで受けるというケースはあまり想定されず、殆どの場合はリバースプロキシとしてWEBサーバを配置し、そのバックエンドにアプリケーションサーバを配置する構成になると思います。 このような構成を取る理由として、下記のようなものが挙げられると思います。 ロギング ヘッダの柔軟な扱い 静的ページのリクエスト処理 URLのパースやrewrite処理など キャッシュの利用など WEBサーバを利用する場合、多くの場合でngi
Go言語でターミナルニコ生コメントビューワー kome 作った - Qiita
komeとは kome is Terminal Niconama Comment Viewer ターミナルで動くニコニコ生放送用のコメントビューワーです。 コメントの送受信、閲覧ができます。 操作はキーボードのみ、vim風のキーバインドを採用しています。 macとlinuxだったら動くと思います。(windowsは未検証) 作った経緯 peco経由でtermbox-goを知る。これで何かつくってみたい。 ↓ tigのようなグラフィカル&インタラクティブなCUIいいなぁ。 ↓ フォロワーさんでコメビュ(Viqo)作っている人がいたので乗っかる。 得られた知見 デッドロックは簡単におきる channelのデッドロックは結構わかりずらくて3日くらい悶々と悩まされました。 例えばこんなコード up := make(chan int, 10) down := make(chan int, 10) /
go-timeoutの話
mackerel-agent 監視対象サーバーにインストールされるメトリクス投稿用のGo製のプログラム 1分毎にMackerel本体のAPIサーバーにメトリクスをPOST デフォルトで各種メトリクスを自動投稿。pluginによる拡張も OSS https://github.com/mackerelio/mackerel-agent mackerel-agentがやっていること 大きく2つのgoroutine metricsのHTTP投稿のためのgoroutine キューの管理、エラー処理等 毎分メトリックを収集管理をするgoroutine 複数のgoroutineを立ち上げてメトリックを取得 チャンネルをキューのようにして通信 Goで書くのに大分向いてる プラグインによる拡張 公式プラグインによるメトリック追加 こちらもGo製 & OSS(p-rお待ちしています) https://gith
リリース、障害情報などのサービスのお知らせ
最新の人気エントリーの配信
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く
GitHub - microsoft/go-winio: Win32 IO-related utilities for Go
Goroutineと channelから はじめるgo言語
