??

????????????????裬???????С??????????????????????????patator??????10?????????????????????????????(class Controller)?????????е?С??????

  gqueues = [Queue(maxsize=10000) for _ in range(self.num_threads)]

    # consumers
    for num in range(self.num_threads):
      pqueue = Queue(maxsize=1000)
      t = Thread(target=self.consume?? args=(gqueues[num]?? pqueue))
      t.daemon = True
      t.start()
      self.thread_report.append(pqueue)
      self.thread_progress.append(Progress())

    # producer
    t = Thread(target=self.produce?? args=(gqueues??))
    t.daemon = True
    t.start()

?????????????????????????????????????????produce?????consume???????????????Queue??self.num_threads????????????????????? -t????????????10??????

??????????????????????Patator????????????????μ????????????ж????