lib/temporal/worker.rb
def start
      workflows.each_pair do |(namespace, task_queue), lookup|
        pollers << workflow_poller_for(namespace, task_queue, lookup)
      end

      activities.each_pair do |(namespace, task_queue), lookup|
        pollers << activity_poller_for(namespace, task_queue, lookup)
      end

      trap_signals

      pollers.each(&:start)

      # keep the main thread alive
      sleep 1 while !shutting_down?
    end
# activity_thread_pool_size: number of threads that the poller can use to run activities.
#   can be set to 1 if you want no paralellism in your activities, at the cost of throughput.
number of threads that the poller can use to run activities.
can be set to 1 if you want no paralellism in your activities, at the cost of throughput.
number of threads that the poller can use to run activities . can be set to 1 if you want no paralellism in your activities at the cost of throughput .
def start
      workflows.each_pair do |(namespace, task_queue), lookup|
        pollers << workflow_poller_for(namespace, task_queue, lookup)
      end
      activities.each_pair do |(namespace, task_queue), lookup|
        pollers << activity_poller_for(namespace, task_queue, lookup)
      end
      trap_signals
      pollers.each(&:start)
      sleep 1 while !shutting_down?
    end
def start workflows . each_pair do | ( namespace , task_queue ) , lookup | pollers << workflow_poller_for ( namespace , task_queue , lookup ) end activities . each_pair do | ( namespace , task_queue ) , lookup | pollers << activity_poller_for ( namespace , task_queue , lookup ) end trap_signals pollers . each ( & :start ) sleep 1 while ! shutting_down? end
activity_thread_pool_size: number of threads that the poller can use to run activities.
activity_thread_pool_size : number of threads that the poller can use to run activities .
# keep the main thread alive