Skip to Content Skip to Search

Shared queue distributor - workers compete for tests (work stealing). Internal/testing helper; not exposed as a public distribution mode.

Methods
A
C
I
N
P
T

Class Public methods

new()

Source: show | on GitHub 

# File activesupport/lib/active_support/testing/parallelization/test_distributor.rb, line 43
def initialize
  @queue = Queue.new
end

Instance Public methods

add_test(test)

Source: show | on GitHub 

# File activesupport/lib/active_support/testing/parallelization/test_distributor.rb, line 47
def add_test(test)
  @queue << test
end

close()

Source: show | on GitHub 

# File activesupport/lib/active_support/testing/parallelization/test_distributor.rb, line 63
def close
  @queue.close
end

interrupt()

Source: show | on GitHub 

# File activesupport/lib/active_support/testing/parallelization/test_distributor.rb, line 55
def interrupt
  @queue.clear
end

pending?()

Source: show | on GitHub 

# File activesupport/lib/active_support/testing/parallelization/test_distributor.rb, line 59
def pending?
  !@queue.empty?
end

take(...)

Source: show | on GitHub 

# File activesupport/lib/active_support/testing/parallelization/test_distributor.rb, line 51
def take(...)
  @queue.pop
end