YUKI Hiroshi
null+****@clear*****
Mon Jan 20 19:26:38 JST 2014
YUKI Hiroshi 2014-01-20 19:26:38 +0900 (Mon, 20 Jan 2014) New Revision: fa190c3ed05f551999613d00b30608b4a7cf962f https://github.com/droonga/drnbench/commit/fa190c3ed05f551999613d00b30608b4a7cf962f Message: Wait published messages with Queue Modified files: lib/drnbench/publish-subscribe/runner.rb Modified: lib/drnbench/publish-subscribe/runner.rb (+9 -6) =================================================================== --- lib/drnbench/publish-subscribe/runner.rb 2014-01-20 19:02:01 +0900 (4f70ef5) +++ lib/drnbench/publish-subscribe/runner.rb 2014-01-20 19:26:38 +0900 (2eed45b) @@ -16,7 +16,7 @@ module Drnbench @config = config @subscribers = [] - @published_messages = [] + @published_messages = Queue.new @feeder = Droonga::Client.new(:tag => @config.engine.tag, :host => @config.engine.host, @@ -44,13 +44,16 @@ module Drnbench end def run - @config.n_publishings.times do |index| + publishing_times =****@confi*****_publishings.times + n_will_be_published_messages =****@subsc***** * publishing_times + publishing_times do |index| do_feed end published_messages = [] - while published_messages.size !=****@confi*****_publishings - published_messages << @receiver.new_message + n_will_be_published_messages.do + # we should implement "timeout" for too slow cases + published_messages << @published_messages.pop end teardown_server @@ -63,8 +66,8 @@ module Drnbench client = Droonga::Client.new(:protocol => :http, :host => @config.protocol_adapter.host, :port => @config.protocol_adapter.port) - client.subscribe(message) do |object| - @published_messages << object + client.subscribe(message) do |published_message| + @published_messages.push(published_message) end @subscribers << client end -------------- next part -------------- HTML����������������������������...Download