Commit bb080660 authored by Guido van Rossum's avatar Guido van Rossum

The usual

parent c6a681a5
...@@ -44,7 +44,10 @@ class Queue: ...@@ -44,7 +44,10 @@ class Queue:
return n return n
def put(self, item): def put(self, item):
"""Put an item into the queue.""" """Put an item into the queue.
If the queue is full, block until a free slot is avaiable.
"""
self.fsema.acquire_lock() self.fsema.acquire_lock()
self.mutex.acquire_lock() self.mutex.acquire_lock()
was_empty = self._empty() was_empty = self._empty()
...@@ -57,6 +60,7 @@ class Queue: ...@@ -57,6 +60,7 @@ class Queue:
def get(self): def get(self):
"""Gets and returns an item from the queue. """Gets and returns an item from the queue.
This method blocks if necessary until an item is available. This method blocks if necessary until an item is available.
""" """
self.esema.acquire_lock() self.esema.acquire_lock()
...@@ -74,6 +78,7 @@ class Queue: ...@@ -74,6 +78,7 @@ class Queue:
# raise Empty if the queue is empty or temporarily unavailable # raise Empty if the queue is empty or temporarily unavailable
def get_nowait(self): def get_nowait(self):
"""Gets and returns an item from the queue. """Gets and returns an item from the queue.
Only gets an item if one is immediately available, Otherwise Only gets an item if one is immediately available, Otherwise
this raises the Empty exception if the queue is empty or this raises the Empty exception if the queue is empty or
temporarily unavailable. temporarily unavailable.
......
...@@ -396,6 +396,8 @@ class StreamRequestHandler(BaseRequestHandler): ...@@ -396,6 +396,8 @@ class StreamRequestHandler(BaseRequestHandler):
def finish(self): def finish(self):
self.wfile.flush() self.wfile.flush()
self.wfile.close()
self.rfile.close()
class DatagramRequestHandler(BaseRequestHandler): class DatagramRequestHandler(BaseRequestHandler):
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment