Skip to content

Commit c4e8590

Browse files
committed
Adding non-blocking sample
1 parent 02bb9f4 commit c4e8590

File tree

2 files changed

+15
-0
lines changed

2 files changed

+15
-0
lines changed

README.md

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -49,6 +49,11 @@ queue.process(false, 15) do |message|
4949
puts "'#{message}'"
5050
end
5151

52+
# Process messages in a non blocking-way
53+
# A soon as the queue is empty, the block will exit
54+
queue.process(true) do |message|
55+
puts "'#{message}'"
56+
end
5257
```
5358
Contributing to redis-queue
5459
----------------

example/non-blocking.rb

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,10 @@
1+
require "redis-queue"
2+
3+
redis = Redis.new
4+
5+
queue = Redis::Queue.new('__test', 'bp__test', :redis => redis)
6+
queue.clear true
7+
8+
100.times { queue << rand(100) }
9+
10+
queue.process(true) {|m| puts m}

0 commit comments

Comments
 (0)