Fix TypeError: 'bool' object is not callable
Thread has a method called stop, ActiveWFObject._stop will override the parent one. Therefore I have to rename _stop.
This commit is contained in:
@@ -9,15 +9,15 @@ class ActiveWFObject(Thread):
|
|||||||
Thread.__init__(self)
|
Thread.__init__(self)
|
||||||
self.name = str(type(self))
|
self.name = str(type(self))
|
||||||
self.queue = Queue()
|
self.queue = Queue()
|
||||||
self._stop = False
|
self._stopMe = False
|
||||||
self.start()
|
self.start()
|
||||||
|
|
||||||
def run(self):
|
def run(self):
|
||||||
while not self._stop:
|
while not self._stopMe:
|
||||||
message = self.queue.get()
|
message = self.queue.get()
|
||||||
self._dispatch(message)
|
self._dispatch(message)
|
||||||
if message[0] == 'die':
|
if message[0] == 'die':
|
||||||
self._stop = True
|
self._stopMe = True
|
||||||
|
|
||||||
def send(receiver, message):
|
def send(receiver, message):
|
||||||
receiver.queue.put(message)
|
receiver.queue.put(message)
|
||||||
@@ -116,7 +116,7 @@ class WordFrequencyController(ActiveWFObject):
|
|||||||
for (w, f) in word_freqs[0:25]:
|
for (w, f) in word_freqs[0:25]:
|
||||||
print w, ' - ', f
|
print w, ' - ', f
|
||||||
send(self._storage_manager, ['die'])
|
send(self._storage_manager, ['die'])
|
||||||
self._stop = True
|
self._stopMe = True
|
||||||
|
|
||||||
#
|
#
|
||||||
# The main function
|
# The main function
|
||||||
|
|||||||
Reference in New Issue
Block a user