class_docstr: A simple pool of BytesIO objects with a weak memory ceiling.
class_docstr_tok: ["A","simple","pool","of","BytesIO","objects","with","a","weak","memory","ceiling","."]
docstr: The number of threads blocked waiting on memory.
docstr_tok: ["The","number","of","threads","blocked","waiting","on","memory","."]
code: def queued(self):
      """The number of threads blocked waiting on memory."""
      with self._lock:
          return len(self._waiters)
  
file_path: kafka-python/kafka/producer/buffer.py
imports: from __future__ import absolute_import, division
  import collections
  import io
  import threading
  import time
  from kafka.metrics.stats import Rate
  import kafka.errors
label_desc: Use image node_id 4 for calling the SimpleBufferPool obj's underlying member method code with example usage: obj.queued() and returns: len