fix threadpool test

This commit is contained in:
caryoscelus 2023-07-20 18:28:21 +00:00
parent 260c4e626b
commit 51a6eaa057

View file

@ -15,11 +15,9 @@ class TestThreadPool:
@pool.wrap @pool.wrap
def blocker(): def blocker():
events.append("S") events.append("S")
out = 0 time.sleep(0.001)
for i in range(10000000): events.append("M")
if i == 3000000: time.sleep(0.001)
events.append("M")
out += 1
events.append("D") events.append("D")
return out return out
@ -30,9 +28,6 @@ class TestThreadPool:
assert events == ["S"] * 3 + ["M"] * 3 + ["D"] * 3 assert events == ["S"] * 3 + ["M"] * 3 + ["D"] * 3
res = blocker()
assert res == 10000000
def testLockBlockingSameThread(self): def testLockBlockingSameThread(self):
lock = ThreadPool.Lock() lock = ThreadPool.Lock()