code: def abort(self, err):
          
          if _debug: IOQueue._debug("abort %r", err)
  
          # send aborts to all of the members
          try:
              for iocb in self.queue:
                  iocb.ioQueue = None
                  iocb.abort(err)
  
              # flush the queue
              self.queue = []
  
              # the queue is now empty, clear the event
              self.notempty.clear()
          except ValueError:
              pass
docs: Abort all of the control blocks in the queue.