Merge pull request #329 from FlySnake/send_queue_overflow

In queues added option to remove first element on addind new if queue is full
This commit is contained in:
Mike Taylor
2015-04-11 19:46:26 -04:00
2 changed files with 8 additions and 3 deletions

View File

@@ -291,7 +291,7 @@ class XMLStream(object):
self.event_queue = Queue()
#: A queue of string data to be sent over the stream.
self.send_queue = Queue()
self.send_queue = Queue(maxsize=256)
self.send_queue_lock = threading.Lock()
self.send_lock = threading.RLock()