|
|
|
@ -75,8 +75,7 @@ class AsynchronousExtractor(Extractor):
|
|
|
|
|
Extractor.__init__(self)
|
|
|
|
|
queue_size = int(config.get("general", "queue-size", fallback=5))
|
|
|
|
|
self.__queue = queue.Queue(maxsize=queue_size)
|
|
|
|
|
self.__thread = threading.Thread(target=self.async_items)
|
|
|
|
|
# self.__thread = threading.Thread(target=self.async_images, daemon=True)
|
|
|
|
|
self.__thread = threading.Thread(target=self.async_items, daemon=True)
|
|
|
|
|
|
|
|
|
|
def __iter__(self):
|
|
|
|
|
get = self.__queue.get
|
|
|
|
|