Class: Binpacker::WorkerQueue

Inherits:
Object
  • Object
show all
Includes:
Enumerable, Enumerable[untyped]
Defined in:
lib/binpacker/worker_queue.rb,
sig/binpacker/worker_queue.rbs

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(worker_id, tests = []) ⇒ WorkerQueue

Returns a new instance of WorkerQueue.

Parameters:



9
10
11
12
13
 
# File 'lib/binpacker/worker_queue.rb', line 9

def initialize(worker_id, tests = [])
  @worker_id = worker_id
  @tests = tests.dup
  @index = 0
end

Instance Attribute Details

#worker_id ⇒ Integer (readonly)

Returns the value of attribute worker_id.

Returns:



7
8
9
 
# File 'lib/binpacker/worker_queue.rb', line 7

def worker_id
  @worker_id
end

Instance Method Details

#each {|arg0| ... } ⇒ void

This method returns an undefined value.

Yields:

Yield Parameters:

  • arg0 (Object)

Yield Returns:

  • (void) 


47
48
49
 
# File 'lib/binpacker/worker_queue.rb', line 47

def each(&block)
  @tests[@index..].each(&block)
end

#empty? ⇒ Boolean

Returns:



27
28
29
 
# File 'lib/binpacker/worker_queue.rb', line 27

def empty?
  @index >= @tests.size
end

#peek ⇒ Object

Returns:



22
23
24
25
 
# File 'lib/binpacker/worker_queue.rb', line 22

def peek
  return nil if empty?
  @tests[@index]
end

#pop ⇒ Object

Returns:



15
16
17
18
19
20
 
# File 'lib/binpacker/worker_queue.rb', line 15

def pop
  return nil if empty?
  test = @tests[@index]
  @index += 1
  test
end

#push(test) ⇒ Object

Parameters:

Returns:



43
44
45
 
# File 'lib/binpacker/worker_queue.rb', line 43

def push(test)
  @tests << test
end

#remaining ⇒ Array[untyped]

Returns:



35
36
37
 
# File 'lib/binpacker/worker_queue.rb', line 35

def remaining
  @tests[@index..] || []
end

#size ⇒ Integer

Returns:



31
32
33
 
# File 'lib/binpacker/worker_queue.rb', line 31

def size
  @tests.size - @index
end

#total_weight(timings) ⇒ Float

Parameters:

Returns:



39
40
41
 
# File 'lib/binpacker/worker_queue.rb', line 39

def total_weight(timings)
  remaining.sum(0.0) { |t| timings.fetch(t.key, Timing::DEFAULT_WEIGHT) }
end