def _watch_load(self) -> None:
while not self.shutdown_pending.wait(<NUM_LIT:1>):<EOL><INDENT>self._current_load = os.getloadavg()[<NUM_LIT:0>]<EOL><DEDENT>
Pause consuming messages if lood goes above the allowed limit.