mirror of
https://github.com/python/cpython.git
synced 2025-10-25 18:54:53 +00:00
Refactor if/elif chain for clarity and speed
This commit is contained in:
parent
f7bd964fb5
commit
ae138cbfbb
1 changed files with 10 additions and 11 deletions
21
Lib/Queue.py
21
Lib/Queue.py
|
|
@ -102,18 +102,17 @@ def put(self, item, block=True, timeout=None):
|
|||
"""
|
||||
self.not_full.acquire()
|
||||
try:
|
||||
if not block:
|
||||
if self.maxsize > 0 and self._qsize() == self.maxsize:
|
||||
raise Full
|
||||
elif timeout is None:
|
||||
if self.maxsize > 0:
|
||||
if self.maxsize > 0:
|
||||
if not block:
|
||||
if self._qsize() == self.maxsize:
|
||||
raise Full
|
||||
elif timeout is None:
|
||||
while self._qsize() == self.maxsize:
|
||||
self.not_full.wait()
|
||||
else:
|
||||
if timeout < 0:
|
||||
elif timeout < 0:
|
||||
raise ValueError("'timeout' must be a positive number")
|
||||
endtime = _time() + timeout
|
||||
if self.maxsize > 0:
|
||||
else:
|
||||
endtime = _time() + timeout
|
||||
while self._qsize() == self.maxsize:
|
||||
remaining = endtime - _time()
|
||||
if remaining <= 0.0:
|
||||
|
|
@ -152,9 +151,9 @@ def get(self, block=True, timeout=None):
|
|||
elif timeout is None:
|
||||
while not self._qsize():
|
||||
self.not_empty.wait()
|
||||
elif timeout < 0:
|
||||
raise ValueError("'timeout' must be a positive number")
|
||||
else:
|
||||
if timeout < 0:
|
||||
raise ValueError("'timeout' must be a positive number")
|
||||
endtime = _time() + timeout
|
||||
while not self._qsize():
|
||||
remaining = endtime - _time()
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue