Displaying 1 result from an estimated 1 matches for "feed_fetch_limit".
2005 Nov 04
0
Threads and Active Reccord
...def fill_feed_queue
last_at = 0
@queue = SizedQueue.new(10) # with a capacity for 10
# we do the queue filling in a single thread that runs until no more
items are left to add
Thread.new do
loop do
logger.debug("Fetching next block of feeds: limit =
#{FEED_FETCH_LIMIT}, offset = #{last_at}")
feeds = Feed.find(:all, :limit => FEED_FETCH_LIMIT, :offset =>
last_at)
break if feeds == nil || feeds.length == 0
last_at += feeds.length
# add each feed found to the queue
feeds.each do |feed|
fee...