class Concurrent::CyclicBarrier

def number_waiting

Returns:
  • (Fixnum) - the number of threads currently waiting on the barrier 
def number_waiting
  synchronize { @number_waiting }
end