code: def _reset(self, after_fork=False):
      if after_fork:
          self._notempty._at_fork_reinit()
      else:
          self._notempty = threading.Condition(threading.Lock())
      self._buffer = collections.deque()
      self._thread = None
      self._jointhread = None
      self._joincancelled = False
      self._closed = False
      self._close = None
      self._send_bytes = self._writer.send_bytes
      self._recv_bytes = self._reader.recv_bytes
      self._poll = self._reader.poll
  
imports: import sys
  import os
  import threading
  import collections
  import time
  import types
  import weakref
  import errno
  from queue import Empty, Full
  import _multiprocessing
  from .None import connection
  from .None import context
  from .util import debug, info, Finalize, register_after_fork, is_exiting
label_desc: Use image node_id 5 for calling the Queue obj's underlying member method code with example usage: obj._reset(after_fork) without return types