def queue_dispatcher(force=False):
 __lock_.acquire()
 try:
  QUEUE.clear()
 finally:
  __lock_.release()

def queue_dispatcher ( force = False ) : __lock_ . acquire ( ) try : QUEUE . clear ( ) finally : __lock_ . release ( )
default implementation of queue dispatcher .