Guest User

Untitled

a guest
Aug 26th, 2018
105
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.61 KB | None | 0 0
  1. # server.rb
  2. def response(env)
  3. ...
  4. db = EventMachine::Synchrony::ConnectionPool.new(size: 25) do
  5. Mysql2::EM::Client.new({
  6. :adapter => 'em_mysql2',
  7. :database => 'shard001',
  8. :username => 'xxx',
  9. :password => 'xxx',
  10. :host => 'localhost',
  11. :reconnect => true})
  12. end
  13.  
  14. multi = EventMachine::Synchrony::Multi.new
  15.  
  16. ids.each do |id|
  17. multi.add id, db.aquery("select * from users where id = #{id}")
  18. end
  19.  
  20. users = []
  21. res = multi.perform
  22. res.responses[:callback].each do |res|
  23. res.last.callback{|r| users << r.first}
  24. end
  25. ...
  26. end
Add Comment
Please, Sign In to add comment