(self)
| 432 | |
| 433 | class BoundedSemaphoreTest(AsyncTestCase): |
| 434 | def test_release_unacquired(self): |
| 435 | sem = locks.BoundedSemaphore() |
| 436 | self.assertRaises(ValueError, sem.release) |
| 437 | # Value is 0. |
| 438 | sem.acquire() |
| 439 | # Block on acquire(). |
| 440 | future = asyncio.ensure_future(sem.acquire()) |
| 441 | self.assertFalse(future.done()) |
| 442 | sem.release() |
| 443 | self.assertTrue(future.done()) |
| 444 | # Value is 1. |
| 445 | sem.release() |
| 446 | self.assertRaises(ValueError, sem.release) |
| 447 | |
| 448 | |
| 449 | class LockTests(AsyncTestCase): |