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