Contents

require 'rubygems'
require '../lib/gearman'

# String reverse worker 

servers = ['localhost:4730']

t = nil
jobnum = 0

(0..1).each do 
  t = Thread.new {
    w = Gearman::Worker.new(servers)
    w.add_ability('reverse_string') do |data,job|
      result = data.reverse
      puts "Job: #{job.inspect} Data: #{data.inspect} Reverse: #{result} "
      puts "Completed job ##{jobnum}"
      jobnum += 1
      result
    end
    loop { w.work }
  }
end

puts "Waiting for threads..."
t.join

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
gearman-ruby-3.0.8	examples/worker_reverse_string.rb
gearman-ruby-3.0.7	examples/worker_reverse_string.rb
gearman-ruby-3.0.6	examples/worker_reverse_string.rb
gearman-ruby-3.0.4	examples/worker_reverse_string.rb
gearman-ruby-3.0.3	examples/worker_reverse_string.rb
gearman-ruby-3.0.1	examples/worker_reverse_string.rb