Class ThreadedNotifier

Initialization, initialize base classes. read_freq, threshold and timeout parameters are used when looping.

Parameters:

• watch_manager (WatchManager instance) - Watch Manager.
• default_proc_fun (instance of ProcessEvent) - Default processing method. See base class.
• read_freq (int) - if read_freq == 0, events are read asap, if read_freq is > 0, this thread sleeps max(0, read_freq - timeout) seconds.
• threshold (int) - File descriptor will be read only if the accumulated size to read becomes >= threshold. If != 0, you likely want to use it in combination with an appropriate value set for read_freq because without that you would keep looping without really reading anything and that until the amount of events to read is >= threshold. At least with read_freq you might sleep.
• timeout (int) - https://docs.python.org/3/library/select.html#polling-objects

Overrides: object.__init__

Stop notifier's loop. Stop notification. Join the thread.

Overrides: Notifier.stop

Thread's main loop. Don't meant to be called by user directly. Call inherited start() method instead.

Events are read only once time every min(read_freq, timeout) seconds at best and only if the size of events to read is >= threshold.

Parameters:

• callback - Functor called after each event processing iteration. Expects to receive the notifier object (self) as first parameter. If this function returns True the loop is immediately terminated otherwise the loop method keeps looping.
• daemonize - This thread is daemonized if set to True.
• args - Optional and relevant only if daemonize is True. Remaining keyworded arguments are directly passed to daemonize see __daemonize() method. If pid_file=None or is set to a pathname the caller must ensure the file does not exist before this method is called otherwise an exception pyinotify.NotifierError will be raised. If pid_file=False it is still daemonized but the pid is not written in any file.

Overrides: Notifier.loop

Start thread's loop: read and process events until the method stop() is called. Never call this method directly, instead call the start() method inherited from threading.Thread, which then will call run() in its turn.

Overrides: threading.Thread.run