code: def __init__(self, maxsize=0, *, ctx):
      if maxsize <= 0:
          # Can raise ImportError (see issues #3770 and #23400)
          from .synchronize import SEM_VALUE_MAX as maxsize
      self._maxsize = maxsize
      self._reader, self._writer = connection.Pipe(duplex=False)
      self._rlock = ctx.Lock()
      self._opid = os.getpid()
      if sys.platform == "win32":
          self._wlock = None
      else:
          self._wlock = ctx.Lock()
      self._sem = ctx.BoundedSemaphore(maxsize)
      # For use by concurrent.futures
      self._ignore_epipe = False
      self._reset()
  
      if sys.platform != "win32":
          register_after_fork(self, Queue._after_fork)
  
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 1 to create a new Queue object from inherited base classes: object with example: obj = Queue(maxsize)