Executor (Java Platform SE 8)
既知のすべてのサブインタフェース: ExecutorService, ScheduledExecutorService 既知のすべての実装クラス: AbstractExecutorService、ForkJoinPool、ScheduledThreadPoolExecutor、ThreadPoolExecutor public interface Executor 送信されたRunnableタスクを実行するオブジェクトです。このインタフェースは、タスク送信を各タスクの実行方式(スレッドの使用やスケジューリングの詳細などを含む)から分離する方法を提供します。通常、Executorは、明示的にスレッドを作成するかわりに使用されます。たとえば、タスク・セットごとにnew Thread(new(RunnableTask())).start()を呼び出すかわりに、次を使用できます。 Executor
rubyでカウンティングセマフォ - Qiita
require 'monitor' class CountingSemaphore def initialize(count) @count = count @monitor = Monitor.new @zero_cond = @monitor.new_cond end def synchronize @monitor.synchronize do @zero_cond.wait_while{ @count == 0 } @count -= 1 end ret = yield @monitor.synchronize do @count += 1 @zero_cond.broadcast end ret end end cs = CountingSemaphore.new(10) Array.new(100) do Thread.start do cs.synchronize{ `sle
Rubyで「スレッドの同時実行数を制限する」シンプルな方法 - Qiita
Rubyでスレッドの同時実行数を制限します。 カウンティングセマフォを使えば良いのですが、標準添付ライブラリには入ってない（多分）ので、実装します。 素直にやるとこういう感じ -> rubyでカウンティングセマフォ カウンタとMutexを用意して、カウンタが0の時に待つ機構を作って…と、割とめんどくさいことをしないといけません。 シンプルに 標準添付ライブラリのQueueを使えばこれらの処理がサクッと実装できちゃいます。 require 'thread' locks = Queue.new 2.times { locks.push :lock } Array.new(10) do |i| Thread.new do lock = locks.pop print "#{i}\n" sleep 2 locks.push lock end end.each(&:join) このコードでは10スレ
セマフォ - Wikipedia
語源の腕木式信号機 セマフォ（英: semaphore）とは、計算機科学において、並行プログラミング環境での複数の実行単位（主にプロセス）が共有する資源にアクセスするのを制御する際の、単純だが便利な抽象化を提供する変数または抽象データ型である。 概要[編集] セマフォは、ある資源が何個使用可能かを示す記録と考えればわかりやすく、それにその資源を使用する際や解放する際にその記録を「安全に」（すなわち競合状態となることなく）書き換え、必要に応じて資源が使用可能になるまで待つ操作が結びついている。セマフォは競合状態を防ぐ便利なツールであるが、セマフォを使うことでプログラムにおける競合状態がなくなると保証するものではない。任意個の資源を扱うセマフォをカウンティングセマフォ、値が0と1に制限されている（ロック/アンロック、使用可能/使用不可の意味がある）セマフォをバイナリセマフォと呼ぶ。後者はミュー
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
)
ロック (計算機科学) - Wikipedia
計算機科学におけるロック (英: lock) とは、計算機システム内に複数の動作主体（プロセスやスレッドなど）のある環境で、データやデバイスなどの計算資源（リソース）へのアクセス制限を課す同期機構。ロックは並行性制御ポリシーを実施する手法のひとつである。アクセス制限を課す動作を「ロックする」、「ロックを取得する」などと表現する。また対義語として、制限を解除することをアンロック（英: unlock）という（ロック解放、ロック解除とも）。 概要[編集] ロックは、複数の動作主体が同一のリソースに対して状態を変更する動作を行うとき、不整合な状態が起こらないように制御する並行性制御において用いられる手法の一つである。ある動作主体がロックしたリソースへは、基本的には他の主体による利用は妨げられる。実際には、完全に利用をさせないロックは性能低下が著しいため、複数の主体が取得可能なロックや、他者の読み出
Beyond Functional Programming with Elixir and Erlang « Plataformatec Blog
I would like to add a slightly different perspective to functional programming in the Erlang VM: functional programming is not a goal in the Erlang VM. It is a means to an end. When designing the Erlang language and the Erlang VM, Joe, Mike and Robert did not aim to implement a functional programming language, they wanted a runtime where they could build distributed, fault-tolerant applications. I
並行計算 - Wikipedia
並行計算（へいこうけいさん、英: Concurrent computing）とは、複数の計算あるいはアルゴリズムを、同一期間に同時実行させつつ相互に同調（コンカレント）させて、次の期間開始までに互いに完遂させるという計算形態を意味している。非同期なメッセージパッシングではその完遂の抽象化も可能になる。対義語は順次計算（シーケンシャル）である。並行コンピューティングとも邦訳される。並行プログラミング（Concurrent programming）とも言われる。 並行計算は、コンピュータプログラムやコンピュータネットワークの重要な特性であり、各プロセスの各スレッド制御などがその要点になる[1]。並行計算下の各スレッドは、一定の制約内で他のスレッドの完了を待つことなく同時にそれぞれ進行できる。非同期では他のスレッドの応答も一定の制約内で待たなくてよくなる。エドガー・ダイクストラやアントニー・ホー
1
リリース、障害情報などのサービスのお知らせ
最新の人気エントリーの配信
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く
GitHub - divan/gotrace: Concurrency tracer and visualizer for Go (Golang) programming language
Learn Concurrency by Making a Countdown Latch in Ruby — SitePoint
VS100-055 ASP.NET SignalR でリアルタイム Web 開発
RailsConf 2016 - Introduction to Concurrency in Ruby by Thijs Cadier