Lines Matching full:acquire
23 # .acquire()
24 # acquire the lock associated with the condition
58 # condition object can (must) be .acquire'ed and .release'ed directly.
87 # condition.acquire()
92 # # did a .wait, *and* acquire the lock again before .wait
109 # condition.acquire()
133 # B_done.acquire() B_done.acquire(); B_done.release()
138 # Because B_done was in the acquire'd state at the time B was spawned,
139 # B's attempt to acquire B_done can't succeed until A has done its
275 # the lock actually used by .acquire() and .release()
279 if hasattr(lock, 'acquire') and \
288 self.checkout.acquire()
298 def acquire(self): member in condition
299 self.mutex.acquire()
308 "condition must be .acquire'd when .wait() invoked"
310 idlock.acquire()
318 checkout.acquire(); idlock.acquire()
332 mutex.acquire()
342 self.idlock.acquire()
365 full.acquire()
380 self.posted.acquire()
386 self.posted.acquire()
391 self.posted.acquire()
397 self.posted.acquire()
411 self.nonzero.acquire()
418 self.nonzero.acquire()
439 self.rwOK.acquire()
446 self.rwOK.acquire()
456 self.rwOK.acquire()
464 self.rwOK.acquire()
477 self.rwOK.acquire()
497 tid.acquire(); id = TID = TID+1; tid.release()
498 io.acquire(); alive.append(id); \
505 io.acquire(); print 'thread', tid, 'qsort', l, r; io.release()
522 io.acquire(); print 'thread', tid, 'qsort done'; \
527 io.acquire(); print 'thread', tid, 'randomizing array'; \
530 wh.acquire(); j = randint(0,i); wh.release()
532 io.acquire(); print 'thread', tid, 'randomizing done'; \
544 io.acquire(); print 'thread', tid, 'randomizing', a; \
550 io.acquire(); print 'thread', tid, 'sorting', a; io.release()
556 io.acquire(); print 'thread', tid, 'entering barrier'; \
559 io.acquire(); print 'thread', tid, 'leaving barrier'; \
561 io.acquire(); alive.remove(tid); io.release()