Lines Matching refs:cond
396 cond = asyncio.Condition()
400 await cond.acquire()
401 if await cond.wait():
406 await cond.acquire()
407 if await cond.wait():
412 await cond.acquire()
413 if await cond.wait():
423 self.assertFalse(cond.locked())
425 self.assertTrue(await cond.acquire())
426 cond.notify()
429 self.assertTrue(cond.locked())
431 cond.release()
434 self.assertTrue(cond.locked())
436 cond.notify(2)
439 self.assertTrue(cond.locked())
441 cond.release()
444 self.assertTrue(cond.locked())
446 cond.release()
449 self.assertTrue(cond.locked())
459 cond = asyncio.Condition()
460 await cond.acquire()
462 wait = asyncio.create_task(cond.wait())
466 self.assertFalse(cond._waiters)
467 self.assertTrue(cond.locked())
470 cond = asyncio.Condition()
472 await cond.acquire()
473 self.assertTrue(cond.locked())
475 wait_task = asyncio.create_task(cond.wait())
477 self.assertFalse(cond.locked())
480 await cond.acquire()
481 self.assertTrue(cond.locked())
482 cond.notify()
484 asyncio.get_running_loop().call_soon(cond.release)
492 self.assertTrue(cond.locked())
498 cond = asyncio.Condition()
502 async with cond:
504 await cond.wait()
509 await cond.acquire()
510 cond.notify()
514 cond.release()
521 cond = asyncio.Condition()
523 await cond.wait()
526 cond = asyncio.Condition()
535 await cond.acquire()
536 if await cond.wait_for(predicate):
538 cond.release()
546 await cond.acquire()
547 cond.notify()
548 cond.release()
553 await cond.acquire()
554 cond.notify()
555 cond.release()
563 cond = asyncio.Condition()
566 res = await cond.wait_for(lambda: [1, 2, 3])
570 await cond.wait_for(lambda: False)
573 cond = asyncio.Condition()
577 await cond.acquire()
578 if await cond.wait():
580 cond.release()
584 await cond.acquire()
585 if await cond.wait():
587 cond.release()
591 await cond.acquire()
592 if await cond.wait():
594 cond.release()
604 await cond.acquire()
605 cond.notify(1)
606 cond.release()
610 await cond.acquire()
611 cond.notify(1)
612 cond.notify(2048)
613 cond.release()
625 cond = asyncio.Condition()
630 await cond.acquire()
631 if await cond.wait():
633 cond.release()
637 await cond.acquire()
638 if await cond.wait():
640 cond.release()
649 await cond.acquire()
650 cond.notify_all()
651 cond.release()
661 cond = asyncio.Condition()
662 self.assertRaises(RuntimeError, cond.notify)
665 cond = asyncio.Condition()
666 self.assertRaises(RuntimeError, cond.notify_all)
669 cond = asyncio.Condition()
670 self.assertTrue('unlocked' in repr(cond))
671 self.assertTrue(RGX_REPR.match(repr(cond)))
673 await cond.acquire()
674 self.assertTrue('locked' in repr(cond))
676 cond._waiters.append(mock.Mock())
677 self.assertTrue('waiters:1' in repr(cond))
678 self.assertTrue(RGX_REPR.match(repr(cond)))
680 cond._waiters.append(mock.Mock())
681 self.assertTrue('waiters:2' in repr(cond))
682 self.assertTrue(RGX_REPR.match(repr(cond)))
685 cond = asyncio.Condition()
686 self.assertFalse(cond.locked())
687 async with cond:
688 self.assertTrue(cond.locked())
689 self.assertFalse(cond.locked())
692 async def f(lock=None, cond=None):
695 if cond is None:
696 cond = asyncio.Condition(lock)
697 self.assertIs(cond._lock, lock)
699 self.assertFalse(cond.locked())
700 async with cond:
702 self.assertTrue(cond.locked())
704 self.assertFalse(cond.locked())
707 self.assertTrue(cond.locked())
709 self.assertFalse(cond.locked())
729 cond = asyncio.Condition(lock)
730 # cond.acquire() will trigger waiting on the lock
736 await cond.acquire()
744 cond = asyncio.Condition(lock)
745 cond._loop = loop
750 await cond.wait()