Timer Decorator and other Functionalities about nameko HOT 1 CLOSED

If I understand correctly there are two questions here:

Q1. Is there any way to know how many threads are running?

It depends what you mean. The ServiceContainer._worker_pool is the pool of Greenthreads used to run workers (i.e. the threads used to execute service methods). You can call pool.running() to find out how many workers are currently active. I guess this is the metric you really want to know? If so, there are better ways to track the information, such as a DependencyProvider that increments a counter on worker_setup and decrements it again on worker_teardown.

Nameko uses threads for other things other than running workers too. Most entrypoint implementations rely on a background thread (e.g. the Timer). If these threads are managed by nameko (which they should be, aren't guaranteed to be) you can find them in the ServiceContainer._active_threads and ServiceContainer._protected_threads attributes.

Q2. Can @timer decorated methods know what interval argument they were called with?

Not in the built-in implementation, but it's pretty easy to create a subclass that passes it in:

from nameko.timer import Timer

class AwareTimer(Timer):
    def handle_timer_tick(self):
        args = (self.interval,)
        kwargs = {}
        self.container.spawn_worker(self, args, kwargs)

aware_timer = AwareTimer.decorator

@aware_timer(interval=10)
def testing(self,interval):
  print interval  # works

The timer entrypoint is entirely declarative though, so why don't you do the following?

interval = 10

class Service:
    @timer(interval)
    def testing(self):
        print(interval)

The user group is a better place for these kind of questions. If you have any more, please ask them there.

from nameko.