From c6f2c6f924e6b263be5a3ba4a4eb7049f27544d3 Mon Sep 17 00:00:00 2001 From: Steve Kemp Date: Mon, 18 Jan 2016 14:16:07 +0200 Subject: Removed queue-examples. These are no longer required now we're sure we understand the process of adding jobs to the queue without duplication. --- queue/zset/run.rb | 45 --------------------------------------------- 1 file changed, 45 deletions(-) delete mode 100755 queue/zset/run.rb (limited to 'queue/zset/run.rb') diff --git a/queue/zset/run.rb b/queue/zset/run.rb deleted file mode 100755 index b6990ff..0000000 --- a/queue/zset/run.rb +++ /dev/null @@ -1,45 +0,0 @@ -#!/usr/bin/ruby - -require "redis" -require 'pp' -@redis = Redis.new(:host => "127.0.0.1") - - - -def fetch(timeout = 1) - job = nil - - loop do - job = @redis.ZRANGE('zset', '0', '0') - - if !job.empty? - # We only have one entry in our array - job = job[0] - - # Remove from the queue - @redis.zrem('zset', job ); - - return job - else - sleep(timeout) - end - - end -end - -seen = [] - -while( x = fetch() ) - puts "Got job : #{x}" - if seen.include?(x) - puts "Already seen #{x}" - break - end - - seen << x - - if ( x =~ /test 2/i ) - puts "TEST 2 - sleeping" - sleep 5 - end -end -- cgit v1.2.1