def run(self): while not self.stopped(): self.network.push_to_random() time.sleep(max(random.normalvariate(bptc.push_waiting_time_mu, bptc.push_waiting_time_sigma), 0))