class_docstr: Stripped-down fork of the standard library Queue that is closeable.
class_docstr_tok: ["Stripped-down","fork","of","the","standard","library","Queue","that","is","closeable","."]
docstr: Create a queue object with a given maximum size.
  
  Args:
    maxsize: int size of queue. If <= 0, the queue size is infinite.
docstr_tok: ["Create","a","queue","object","with","a","given","maximum","size",".","Args",":","maxsize",":","int","size","of","queue",".","If","<","=","0",",","the","queue","size","is","infinite","."]
code: def __init__(self, maxsize=0):
      """Create a queue object with a given maximum size.
  
      Args:
        maxsize: int size of queue. If <= 0, the queue size is infinite.
      """
      self._maxsize = maxsize
      self._queue = collections.deque()
      self._closed = False
      # Mutex must be held whenever queue is mutating; shared by conditions.
      self._mutex = threading.Lock()
      # Notify not_empty whenever an item is added to the queue; a
      # thread waiting to get is notified then.
      self._not_empty = threading.Condition(self._mutex)
      # Notify not_full whenever an item is removed from the queue;
      # a thread waiting to put is notified then.
      self._not_full = threading.Condition(self._mutex)
  
imports: import collections
  import os.path
  import sys
  import threading
  import time
  from tensorflow.python.client import _pywrap_events_writer
  from tensorflow.python.platform import gfile
  from tensorflow.python.platform import tf_logging
  from tensorflow.python.util import compat
label_desc: Use image node_id 1 to create a new CloseableQueue object  with example: obj = CloseableQueue(maxsize)