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 |