def __init__(self, task, worker_class, size=2, dry_run=False, progress_logger=None):
    self.tiles_queue = queue_class(size)
    self.task = task
    self.dry_run = dry_run
    self.procs = []
    self.progress_logger = progress_logger
    conf = base_config()
    for _ in range(size):
        worker = worker_class(self.task, self.tiles_queue, conf)
        worker.start()
        self.procs.append(worker)
def __init__(self, task, worker_class, size=2, dry_run=False, progress_logger=None):
    self.tiles_queue = queue_class(size)
    self.task = task
    self.dry_run = dry_run
    self.procs = []
    self.progress_logger = progress_logger
    conf = base_config()
    for _ in range(size):
        worker = worker_class(self.task, self.tiles_queue, conf)
        worker.start()
        self.procs.append(worker)