em.rb

# -*- coding: utf-8 -*-
require 'eventmachine'

EM.run {
  puts "Main thread => #{Thread.current}"

  EM.add_periodic_timer(5.0){
    puts "#{Thread.current} - main thread add_periodic_timer"
  }

  EM.add_timer(10.0){
    puts "#{Thread.current} - add_timer"
    puts "#{Thread.current} - I will die."
    EM.stop
  }

  EM.next_tick {
    puts "#{Thread.current} - next tick"
  }

  EM.defer {
    puts "#{Thread.current} - defer"
  }

  EM.defer {
    3.times do |i|
      puts "#{Thread.current} - defer2 i=#{i}"
      sleep 2.0
    end
  }

  EM.defer{
    EM.add_periodic_timer(1.0){
      puts "#{Thread.current} - add_periodic_timer on defer(should run on main thread)"
    }
  }

  EM.next_tick {
    puts "#{Thread.current} - next tick2"
    EM.defer {
      puts "#{Thread.current} - defer inside next tick"
    }
  }

}