def init_input_queue(self, func, max_size=0): self.in_queue = JoinableQueue(max_size) func(self.in_queue)