Start worker threads which add data from the generator into the queue. Args: workers (int): number of worker threads max_queue_size (int): queue size (when full, threads could block on `put()`)
(self, workers=1, max_queue_size=10)
source not stored for this graph (policy: none)