Method: Workling::Invokers::ThreadedPoller#started?

Defined in:
lib/workling/invokers/threaded_poller.rb

#started?Boolean

Check if all Worker threads have been started.

Returns:

  • (Boolean)


43
44
45
46
# File 'lib/workling/invokers/threaded_poller.rb', line 43

def started?
  logger.debug("checking if started... list size is #{ worker_threads }")
  Workling::Discovery.discovered_workers.size == worker_threads
end