class ActiveRecord::ConnectionAdapters::ConnectionPool::Queue

def delete(element)

If +element+ is in the queue, remove and return it, or +nil+. 
def delete(element)
  synchronize do
    @queue.delete(element)
  end
end