From: ThomasV Date: Sun, 24 Nov 2013 09:07:12 +0000 (+0400) Subject: fix memory leak (caused by thread never terminating) X-Git-Url: https://git.novaco.in/?p=electrum-server.git;a=commitdiff_plain;h=ca1cec48641795c16f3963d48ddc35416dbbd874 fix memory leak (caused by thread never terminating) --- diff --git a/transports/stratum_tcp.py b/transports/stratum_tcp.py index 5fb26a5..6c36086 100644 --- a/transports/stratum_tcp.py +++ b/transports/stratum_tcp.py @@ -67,7 +67,10 @@ class TcpClientResponder(threading.Thread): def run(self): while not self.session.stopped(): - response = self.session.response_queue.get() + try: + response = self.session.response_queue.get(timeout=10) + except queue.Empty: + continue data = json.dumps(response) + "\n" try: while data: