Plux

gem 'plux'

# start one and only process named 'abc', with 2 threads in it (1 thread if not specified),
# no matter the code below is called how many times in whatever processes/threads
server = Plux.worker(:abc, thread: 2) do

  # prepare thread-safe resources like mq/db, to handle requests
  def prepare
    # @db = ...
  end

  # threads call this method to deal with clients' message
  def process(msg)
    # @db << parse(msg)
  end
end

# clients connect, send msg, and close concurrently
5.times do |n|
  Thread.new do
    client = server.connect
    client.puts "hello"
    client.puts "my name is #{n}"
    client.close
  end
end

class AwesomeServer < Plux::Engine
  # prepare thread-safe resources like mq/db, to handle requests
  def prepare
    # @db = ...
  end

  # threads call this method to deal with clients' message
  def process(msg)
    # @db << parse(msg)
  end
end

a = AwesomeServer.new(:a)
b = AwesomeServer.new(:b)
c = AwesomeServer.new(:c, thread: 4)

a_client = a.connect
b_client = b.connect
c_client = c.connect
c_client_2 = c.connect