| 111 | l.clear() |
| 112 | |
| 113 | def test_cancel(self): |
| 114 | l = [] |
| 115 | fun = lambda x: l.append(x) |
| 116 | scheduler = sched.scheduler(time.time, time.sleep) |
| 117 | now = time.time() |
| 118 | event1 = scheduler.enterabs(now + 0.01, 1, fun, (0.01,)) |
| 119 | event2 = scheduler.enterabs(now + 0.02, 1, fun, (0.02,)) |
| 120 | event3 = scheduler.enterabs(now + 0.03, 1, fun, (0.03,)) |
| 121 | event4 = scheduler.enterabs(now + 0.04, 1, fun, (0.04,)) |
| 122 | event5 = scheduler.enterabs(now + 0.05, 1, fun, (0.05,)) |
| 123 | scheduler.cancel(event1) |
| 124 | scheduler.cancel(event5) |
| 125 | scheduler.run() |
| 126 | self.assertEqual(l, [0.02, 0.03, 0.04]) |
| 127 | |
| 128 | @threading_helper.requires_working_threading() |
| 129 | def test_cancel_concurrent(self): |