From 32ef496502bb338ee030b31ce7ba70e789995d9c Mon Sep 17 00:00:00 2001 From: Nathan Fritz Date: Tue, 1 Sep 2009 00:06:46 +0000 Subject: added module config for number of threads --- sleekxmpp/xmlstream/xmlstream.py | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/sleekxmpp/xmlstream/xmlstream.py b/sleekxmpp/xmlstream/xmlstream.py index 958a3b6e..198aba0b 100644 --- a/sleekxmpp/xmlstream/xmlstream.py +++ b/sleekxmpp/xmlstream/xmlstream.py @@ -12,6 +12,8 @@ import traceback import types import xml.sax.saxutils +HANDLER_THREADS = 1 + ssl_support = True try: import ssl @@ -118,8 +120,9 @@ class XMLStream(object): raise RestartStream() def process(self, threaded=True): - self.__thread['eventhandle'] = threading.Thread(name='eventhandle', target=self._eventRunner) - self.__thread['eventhandle'].start() + for t in range(0, HANDLER_THREADS): + self.__thread['eventhandle%s' % t] = threading.Thread(name='eventhandle%s' % t, target=self._eventRunner) + self.__thread['eventhandle%s' % t].start() if threaded: self.__thread['process'] = threading.Thread(name='process', target=self._process) self.__thread['process'].start() @@ -269,7 +272,7 @@ class XMLStream(object): try: event = self.eventqueue.get(True, timeout=5) except queue.Empty: - even = None + event = None if event is not None: etype, handler, stanza = event if etype == 'stanza': -- cgit v1.2.3