Searched refs:_consume (Results 1 – 1 of 1) sorted by relevance
241 def _consume(): function256 consumption = threading.Thread(target=_consume)