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