Sha256: 52c828fb6a083a0676c9b6f0b2c5d0a443f6d7593c8978268addc4debbd98307

Contents?: true

Size: 591 Bytes

Versions: 2

Compression:

Stored size: 591 Bytes

Contents

$LOAD_PATH.unshift("../lib")
require 'rubygems'
require 'logger'
require '../lib/gearman'
servers = ['localhost:4730']

w = Gearman::Worker.new(servers)
logger = Logger.new(STDOUT)

# Add a handler for a "sleep" function that takes a single argument, the
# number of seconds to sleep before reporting success.
w.add_ability("sleep") do |data,job|
 seconds = 10
 logger.info "Sleeping for #{seconds} seconds"
 (1..seconds.to_i).each do |i|
   sleep 1
   # Report our progress to the job server every second.
   job.report_status(i, seconds)
 end
 # Report success.
 true
end

loop { w.work }

Version data entries

2 entries across 2 versions & 1 rubygems

Version Path
gearman-ruby-4.0.3 examples/worker.rb
gearman-ruby-4.0.2 examples/worker.rb