Class: ThrottleQueue::PriorityQueue

Inherits:

Object

• Object
• ThrottleQueue::PriorityQueue

Defined in:

lib/throttle-queue.rb

Overview

:nodoc: all

Instance Method Summary

• #background(id) ⇒ Object
• #empty? ⇒ Boolean
• #foreground(id) ⇒ Object
• #initialize ⇒ PriorityQueue constructor

  A new instance of PriorityQueue.

• #pop ⇒ Object
• #shutdown ⇒ Object
• #shutdown? ⇒ Boolean

Constructor Details

#initialize ⇒ PriorityQueue

Returns a new instance of PriorityQueue.

# File 'lib/throttle-queue.rb', line 162

def initialize
	@mutex = Mutex.new
	@fg = []
	@bg = []
	@received = ConditionVariable.new
	@shutdown = false
end

Instance Method Details

#background(id) ⇒ Object

# File 'lib/throttle-queue.rb', line 185

def background(id)
	@mutex.synchronize {
		unless @shutdown || @bg.include?(id)
			@bg << id
			@received.signal
		end
	}
end

#empty? ⇒ Boolean

Returns:

• (Boolean)

# File 'lib/throttle-queue.rb', line 179

def empty?
	@mutex.synchronize {
		@fg.empty? and @bg.empty?
	}
end

#foreground(id) ⇒ Object

# File 'lib/throttle-queue.rb', line 194

def foreground(id)
	@mutex.synchronize {
		unless @shutdown || @fg.include?(id)
			@fg << id
			if @bg.include?(id)
				@bg.delete id
			else
				@received.signal
			end
		end
	}
end

#pop ⇒ Object

# File 'lib/throttle-queue.rb', line 207

def pop
	@mutex.synchronize {
		if @fg.empty? and @bg.empty?
			@received.wait(@mutex) unless @shutdown
		end

		if @shutdown
		elsif ! @fg.empty?
			@fg.shift
		else
			@bg.shift
		end
	}
end

#shutdown ⇒ Object

# File 'lib/throttle-queue.rb', line 170

def shutdown
	@shutdown = true
	@received.signal
end

#shutdown? ⇒ Boolean

Returns:

• (Boolean)

# File 'lib/throttle-queue.rb', line 175

def shutdown?
	@shutdown
end