Method: Kudzu::Adapter::Memory::Frontier#dequeue
- Defined in:
- lib/kudzu/adapter/memory/frontier.rb
#dequeue(limit: 1) ⇒ Object
22 23 24 25 26 27 28 29 |
# File 'lib/kudzu/adapter/memory/frontier.rb', line 22 def dequeue(limit: 1) @monitor.synchronize do links = @queue.shift(limit) links.each do |link| link.state = 1 end end end |