code: def __init__(self, maxsize=0, *, ctx):
      Queue.__init__(self, maxsize, ctx=ctx)
      self._unfinished_tasks = ctx.Semaphore(0)
      self._cond = ctx.Condition()
  
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 JoinableQueue object from inherited base classes: Queue with example: obj = JoinableQueue(maxsize)