フレームワークに頼って実装していると、そのフレームワークが内部でどの様な仕組みで並列または並行処理しているのかが理解できず、ただ使っているだけの状態になり得ます。

フレームワークの設計者からすると、プログラマがそれらを気にしなくても利用できるというのがプロジェクトのゴールでもあるので、それはそれで正しいのですが「並列処理」や「並行処理」を理解したいというモチベーションでは逆にそれが邪魔をしてしまうかもしれません。

並行処理や並列処理を学ぶのであれば、API サーバ等といった物ではなく、コード片で学び始めるのが良いと思います。

例えば Ruby で Thread と Fiber を使って簡単な処理を実装してみるのが理解を早めると思います。

※ Go でも並行処理を学ぶことはできますが、Go の goroutine はスレッドでありスレッドではない、という特性があるため、並列処理や並行処理がどういった物かを学び始めるには難しいかもしれません。

まずは Fiber を使ったコードです。

def print_chars(s)
  Fiber.new do
    s.each_char do |c|
      Fiber.yield c
    end
  end
end

fiber = print_chars('あいう')
puts fiber.resume 
puts fiber.resume 
puts fiber.resume

この Fiber を使ったコードを実行すると「あ」「い」「う」が3つ表示されます。これのどこが並行処理なんだと思うかもしれませんが、並行処理は「実行状態を複数持つこと」なのです。

一方 Thread を使ったコードを示します。

require 'thread'

def print_chars(a)
  q = Queue.new
  th = Thread.start do 
    a.chars.each do |e|
      q.push e
    end
  end
  th.run
  q
end

v = print_chars('あいう')
puts v.pop
puts v.pop
puts v.pop

同じく「あ」「い」「う」が表示されます。一見、同じ動作になる実装に見えますが、並行と並列には大きな違いがあります。これらの puts での表示処理を print_chars の中に移動してみましょう。

def print_chars(s)
  Fiber.new do
    s.each_char do |c|
      puts c
      Fiber.yield
    end
  end
end

fiber = print_chars('あいう')
fiber.resume 
fiber.resume 
fiber.resume

require 'thread'

def print_chars(a)
  th = Thread.start do 
    a.chars.each do |e|
      puts e
    end
  end
  th
end

th = print_chars('あいう')
th.run
th.join

Fiber は、確かに実行環境が2つありますがそれを動かすためには resume を呼び出さなければなりません。一方で Thread は run を実行した後で勝手に動き出します。

例えば Fiber の方を、2つ同時に呼び出したい場合、それぞれの resume を呼び出さなければなりません。

fiber1 = print_chars('あいう')
fiber2 = print_chars('かきく')
fiber1.resume 
fiber2.resume 
fiber1.resume 
fiber2.resume 
fiber1.resume 
fiber2.resume

Thread は実行してしまえば勝手に並列に実行されます。

require 'thread'

def print_chars(a)
  th = Thread.start do 
    a.chars.each do |e|
      puts e
      sleep 0.1
    end
  end
  th
end

th1 = print_chars('あいう')
th2 = print_chars('かきく')
th1.run
th2.run
th1.join
th2.join

プログラムのパフォーマンスを大きく左右するのは I/O です。ですので Fiber の方は、fiber1 の I/O に伴って fiber2 の実行がブロックされる事になります。一方で Thread は片方のスレッドが I/O で待ちになっても、もう片方のスレッドが実行されます。

結果として、Ruby の Thread は I/O が絡む実装でパフォーマンスが良くなります。

ただし Ruby の Thread は、GIL (Global Interpreter Lock) があるため、安全にスレッド内で変数を触る事ができますが、完全に排他制御されるわけではありません。

class Counter
    attr_accessor :count, :tmp

    def initialize
        @count = 0
        @tmp = 0
    end

    def increment
        @count += 1
    end
end

c = Counter.new

t1 = Thread.start { 1000000.times { c.increment; c.tmp += 1 if c.count.even?; } }
t2 = Thread.start { 1000000.times { c.increment; c.tmp += 1 if c.count.even?; } }

t1.join
t2.join

p c.count # 常に 2000000
p c.tmp   # 100000 でない事もある

これを実行すると最終的な値が 1 だったり 997 だったり 1000 だったりします。

※ これを回避するには Mutex を使わなければなりません。

また Ruby の GIL は I/O が発生するとそのタイミングで競合が起きえます。

当然ながら排他処理を入れると、プログラムが遅くなってしまいます。

処理を同時に実行したいというニーズに「並列」を使うか「並行」を使うかは、要件次第という事が分かると思います。新しい Ruby では Ractor という機能も追加されているため Thread よりも気軽に並列処理を扱う事ができると思います。

r1 = Ractor.new 'あいう'.chars do |arr|
  puts arr.each(&:to_s)
end
r2 = Ractor.new 'かきく'.chars do |arr|
  puts arr.each(&:to_s)
end
r1.take
r2.take

※ これを実行すると混ざって表示される様になります。(タイミングによります)

ぜひこういったコード片で仕組みを学ばれるのが良いと思います。

ちなみに、Fiber の例を実行されたのであれば「じゃぁ、Fiber の resume をもっと賢く呼んでくれたらいいのに、例えば fiber1 が I/O でブロックしている間に fiber2 の resume を呼び出し続けてくれたらいいのに」と感じたかもしれません。これを上手く扱える様にしているプログラミング言語も存在します。その1つが Go です。(Go の宣伝ではありません)