docs: def set_in(self, que_in, num_senders):
          """Set the queue in input and the number of parallel tasks that send inputs"""
          for p in self.processes:
              p.set_in(que_in, num_senders)