Ruby methods are colorless
👋🏼 This is part of series on concurrency, parallelism and asynchronous programming in Ruby. It’s a deep dive, so it’s divided into 10 main parts: Your Ruby programs are always multi-threaded: Part 1 Your Ruby programs are always multi-threaded: Part 2 Consistent, request-local state Ruby methods are colorless Concurrent, colorless Ruby: Part 1, Threads Concurrent, colorless Ruby: Part 2, Fiber a
RailsConf 2018 | The Future of Rails 6: Scalable by Default
We've all heard the phrase "Rails doesn't scale". Long running test suites and no standard for implementing multiple databases makes it hard scale monolithic Rails applications. Rails 6 will start making Rails scalable by default with parallel testing and improved support for using multiple databases. You'll no longer be forced to reinvent the wheel and create your own solution to these problems.
Railsでデータの権限設定:Thread.currentを使ってみる | ちぇらぶ
Rails+deviseで稼働中のAPIに、ユーザー毎の権限設定を追加したい。 実装方法の背景 権限設定には大きく分けて２種類ある。と思う。 １．機能を制御するもの（主にcontrollerで制御する） ２．データを制御するもの（modelで制御しちゃいたい） １はイメージしやすい。各APIを使う権限であり、controllerのメソッドを制御できれば良く、cancancan、pundit等のgemがある。 ２は主に対象データのあるレコードが参照可能か、更新可能かを制御する。 例えば、ユーザーAは、itemモデルのid:1のデータを更新可で、id:2のデータは参照不可。ユーザーBはid:2だけ更新可のような。 ２のようなデータ制御ができるgemを自分は知らない。そこで、current_userをmodelのdefault_scopeで使ってしまうことにした。 いや本当はcontroller
Thread#join (Ruby 3.3 リファレンスマニュアル)
join -> self[permalink][rdoc][edit] join(limit) -> self | nil スレッド self の実行が終了するまで、カレントスレッドを停止します。self が例外により終了していれば、その例外がカレントスレッドに対して発生します。 limit を指定して、limit 秒過ぎても自身が終了しない場合、nil を返します。 [PARAM] limit: タイムアウトする時間を整数か小数で指定します。単位は秒です。 [EXCEPTION] ThreadError: join を実行することによってデッドロックが起きる場合に発生します。またカレントスレッドを join したときにも発生します。 以下は、生成したすべてのスレッドの終了を待つ例です。 threads = [] threads.push(Thread.new { n = rand(5);
Rubyのスレッド周りの話 - Qiita
Rubyのスレッド周りを追ってみた。 最も効率が良いスレッドモデルは結論出ないんじゃないかと（物理的な環境、何を実装するか、性能以外の面でメンテナの問題とか）。 Ruby1.8系 「グリーンスレッド」 Ruby1.8ではOSではなくて仮想マシン(VM)上で実装されたマルチスレッドシステムを採用した。 これを「グリーンスレッド」という。カーネルでスレッドがサポートされていなくても動作する。 つまり、OSに依存せずにマルチスレッドを実現する。 メリット スレッドの起動、並列化の性能 Linux のネイティブスレッドの性能を上回る。つまり、ネイティブスレッドより低コストで起動、並列化を行える。 起動については、独自のアドレス空間を確保する必要がなく、わずかな量の仮想メモリを取得するだけ。 並列化については、カーネルレベルとユーザレベルの切り替えが必要ないことなど。 さまざまなOS間で移植が楽 デ
Rails 5 Create module and class level variables
Rails already provides methods for creating class level and module level variables in the form of cattr** and mattr** suite of methods. In Rails 5, we can go a step further and create thread specific class or module level variables. Here is an example which demonstrates an example on how to use it. 1 2module CurrentScope 3 thread_mattr_accessor :user_permissions 4end 5 6class ApplicationController
Koichi Sasada: A proposal of new concurrency model for Ruby 3 (RubyKaigi2016)
A proposal of new concurrency model for Ruby 3 Koichi Sasada ko1@heroku.com People love “Concurrency” Concurrent RubyKaigi (at least, there are two parallel sessions) Why people love (to discuss) “Concurrency”? •Performance by “Parallel” execution to utilize multiple-cores •Ruby has thread system, but MRI doesn’t permit to allow parallel execution. About this presentation •Show “Why difficult mult
Koichi Sasada: Precompiling Ruby scripts - Myth and Fact (RailsConf 2016)
A proposal of new concurrency model for Ruby 3 Koichi Sasada ko1@heroku.com People love “Concurrency” Concurrent RubyKaigi (at least, there are two parallel sessions) Why people love (to discuss) “Concurrency”? •Performance by “Parallel” execution to utilize multiple-cores About this presentation •Show “Why difficult multi-threads programs” •Propose new concurrent and parallel mechanism idea name
Debugging stuck Ruby processes | Mike Perham
2016-08-05 My Ruby process has stopped doing any work, what’s wrong? This is an uncommon but occasional problem for many people, especially with large applications using lots of native extensions. Step 1 - Thread backtraces A Sidekiq process will print out the backtrace of every thread when you send it the TTIN signal. kill -TTIN <pid> Side note: YMMV for other types of Ruby processes: resque, uni
Thread.new (Ruby 3.3 リファレンスマニュアル)
new(*arg) {|*arg| ... } -> Thread[permalink][rdoc][edit] スレッドを生成して、ブロックの評価を開始します。生成したスレッドを返します。 [PARAM] arg: 引数 arg はそのままブロックに渡されます。スレッドの開始と同時にそのスレッド固有のローカル変数に値を渡すために使用します。 [EXCEPTION] ThreadError: 現在のスレッドが属する ThreadGroup が freeze されている場合に発生します。またブロックを与えられずに呼ばれた場合にも発生します。 注意: 例えば、以下のコードは間違いです。スレッドの実行が開始される前に変数 i が書き変わる可能性があるからです。 for i in 1..5 Thread.new { p i } end 上の例は以下のように書き直すべきです。 for i in 1.
グローバルインタプリタロック(GIL)とは
LL言語がマルチプロセッサ環境のメリットを捨ててまでグローバルインタプリタロックを採用している理由について調べてみた。 その為にはプロセスとスレッドについての前提知識がけっこう必要だったので、ついでにざっくり調べてみた。 LL言語がマルチプロセッサ環境のメリットを捨ててまでGILを実装している理由 結論を先に書くと、LL言語がマルチプロセッサ環境のメリットを捨ててまでGILを実装している一番の理由は、「スレッドセーフではないCで書かれたモジュールをたくさん使っているから」ということになるっぽい。 この結論に至るまでの色々な前提知識についても書いておく。 プロセスとスレッド プロセスとスレッドの特徴をざっくり対比させて書くとこんな感じになる。 ユーザースレッドとカーネルスレッド ユーザースレッド ユーザ空間で実装されたスレッド機構をユーザースレッドと呼ぶ。 1つのプロセス内の複数のスレッドは
Ruby の Monitor と ConditionVariable の使い方 - Mame the hack
Ruby の Monitor と ConditionVariable の使い方 なかなかぐぐっても日本語の資料が見つからなかったので自分で動かしてみた。(ぐぐる能力低い) まずThreadの直列化 require "thread" require "monitor" moni = Monitor.new val = 0 Thread.new { 3.times { puts "thread1 start: #{val}" val+=1 sleep 0.1 puts "thread1 end: #{val}" } } Thread.new { 3.times { puts "thread2 start: #{val}" val+=1 sleep 0.1 puts "thread2 end: #{val}" } } sleep 結果は以下の通り。 start > end, start > en
Ruby: Thread と Fiber - Qiita
th = Thread.new { 3.times { puts "hello" ; sleep 1 } } th.join # メインスレッドが終了しないように子スレッドを待つ
【Ruby on Rails】非同期処理についてその②。 〜マルチスレッドとかマルチプロセスを実装してみた〜 - 訳も知らないで
業務で非同期処理の実装が必要となったので、 前回ぼんやりマルチスレッド、マルチプロセスについて調べてみたのですが… 両方軽く実装してみたのでメモ。 実際に実装してみたところ、マルチプロセスでもマルチスレッドでも 処理時間自体は短縮されたのですが、 マルチプロセスだとメモリは食うしメモリ空間？を共有してくれないので スレッドのほうで実装してみました。 (マルチスレッドで十分なときはそれでいいってことかな？) 〜検証環境〜 Rails:3.2.11 ruby:1.9.3p392 Railsで普通に実装 マルチスレッドで実装 〜リファレンス〜 class Thread 〜とても参考になりました！〜 ActiveRecordを複数スレッド環境で利用する - tech.recompile.net 処理内容はDBからUserのid取ってきているだけです。 threads = [] 10.times.w
RubyのThread、Fiber、Kernel、forkで並列処理やプロセスの深淵へ
連載目次 前回の「RubyのFile／IOクラスで入力と出力、ファイルの読み取りと書き込み、フィルター作成」では、データの入出力について解説しました。連載第11回に当たる今回は、スレッド、ファイバー、プロセスといったトピックについて解説します。 ThreadクラスやFiberクラスを使うことで、Rubyでも並列処理を記述することが可能です。また、前回紹介したIOクラスを使うことで、Rubyプログラムからプロセスを生成して入出力を行えます。 さまざまなプログラミング言語では並列処理のための仕組みが使えるようになっています。もちろんRubyも例外ではなく、ThreadクラスやFiberクラスを使って並列プログラムを書くことができます。 また、RubyからOS固有のコマンドを別のプロセスとして実行したり、自分自身をfork（フォーク）して別プロセスとしてRubyプログラムを実行したりすることがで
class Thread::ConditionVariable (Ruby 3.3 リファレンスマニュアル)
[edit] aliases: ConditionVariable 要約 スレッドの同期機構の一つである状態変数を実現するクラスです。 以下も ConditionVariable を理解するのに参考になります。 https://ruby-doc.com/docs/ProgrammingRuby/html/tut_threads.html#UF Condition Variable とは あるスレッド A が排他領域で動いていたとします。スレッド A は現在空いていないリソースが必要になったので空くまで待つことにしたとします。これはうまくいきません。なぜなら、スレッド A は排他領域で動いているわけですから、他のスレッドは動くことができません。リソースを空けることもできません。スレッド A がリソースの空きを待っていても、いつまでも空くことはありません。 以上のような状況を解決するのが Co
リリース、障害情報などのサービスのお知らせ
最新の人気エントリーの配信
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く
WTF is a Thread
Signal handling in Ruby and its internals<!-- --> • Kir Shatrov
Ruby Fibers: A Simple Example
Better integration between Sidekiq thread count and Active Record pool size. · Issue #2985 · sidekiq/sidekiq
