supervision.rb

class WorkerScheduler
  include Celluloid
  
  def initialize(users)
    @workers = users.map do |user|
      Worker.new(user)
    end
    tick
  end
  
  def tick
    @workers.each { |worker| worker.async.work }
    after(10) { tick }
  end
end

class Worker
  include Celluloid
  
  attr_reader :user
  
  def initialize(user)
    @user = user
  end
  
  def work
    json = Twitter::UserTimeline.fetch(user) # This will block
    # Send JSON off to another actor...
  end
end

class Application < Celluloid::SupervisionGroup
  USERS = %w(bascule brixen headius)

  supervise WorkerScheduler, args: USERS, as: :worker_scheduler
end

Application.run