Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions tornado/locks.py
Original file line number Diff line number Diff line change
Expand Up @@ -122,7 +122,7 @@ def wait(
"""
waiter: Future[bool] = Future()
self._waiters.append(waiter)
if timeout:
if timeout is not None:

def on_timeout() -> None:
if not waiter.done():
Expand Down Expand Up @@ -421,7 +421,7 @@ def acquire(
waiter.set_result(_ReleasingContextManager(self))
else:
self._waiters.append(waiter)
if timeout:
if timeout is not None:

def on_timeout() -> None:
if not waiter.done():
Expand Down
2 changes: 1 addition & 1 deletion tornado/queues.py
Original file line number Diff line number Diff line change
Expand Up @@ -55,7 +55,7 @@ class QueueFull(Exception):


def _set_timeout(future: Future, timeout: None | float | datetime.timedelta) -> None:
if timeout:
if timeout is not None:

def on_timeout() -> None:
if not future.done():
Expand Down
8 changes: 8 additions & 0 deletions tornado/test/queues_test.py
Original file line number Diff line number Diff line change
Expand Up @@ -117,6 +117,14 @@ def test_get_timeout(self):
q.put_nowait(0)
self.assertEqual(0, (yield get))

@gen_test
def test_get_zero_timeout(self):
q: queues.Queue[int] = queues.Queue()
with self.assertRaises(TimeoutError):
yield q.get(timeout=timedelta(seconds=0))
with self.assertRaises(TimeoutError):
yield q.get(timeout=0)

@gen_test
def test_get_timeout_preempted(self):
q: queues.Queue[int] = queues.Queue()
Expand Down