docs: def process_queues(self, forced=False):
          """Process queues if any have data queued"""
  
          with self.lock:
              if (not forced and not self.must_process) or not self.queues_enabled:
                  return
              self.must_process = False
          ARBITRATOR.awaken()