def test_clock(self):
bas = [0]
clk = Clock(100)
s = Semaphore(0)
@activity(clk)
async def foo():
bas[0] += 1
if bas[0] >= 5:
clk.stop()
s.release()
t0 = time()
clk.start()
self.assertTrue(s.acquire(timeout=0.1))
self.assertGreaterEqual(time() - t0, 0.05)
self.assertEqual(bas[0], 5)
评论列表
文章目录