Bug on thread stop

[zhangjr]

Example:
import threading

class StoppableThread?(threading.Thread):

"""Thread class with a stop() method. The thread itself has to check
regularly for the stopped() condition."""

def init(self):

super(StoppableThread?, self).init()
self._stop = threading.Event()

def stop(self):

self._stop.set()

def stopped(self):

return self._stop.isSet()

[zhangjr]

Could be solution.

===
import Queue # or queue in Python 3
import threading

class PrintThread?(threading.Thread):

def init(self, queue):

threading.Thread.init(self)
self.queue = queue

def printfiles(self, p):

for path, dirs, files in os.walk(p):

for f in files:

print(f, file=output)

def run(self):

while True:

result = self.queue.get()
self.printfiles(result)
self.queue.task_done()

class ProcessThread?(threading.Thread):

def init(self, in_queue, out_queue):

threading.Thread.init(self)
self.in_queue = in_queue
self.out_queue = out_queue

def run(self):

while True:

path = self.in_queue.get()
result = self.process(path)
self.out_queue.put(result)
self.in_queue.task_done()

def process(self, path):

# Do the processing job here

pathqueue = Queue.Queue()
resultqueue = Queue.Queue()
paths = getThisFromSomeWhere()

output = codecs.open('file', 'a')

# spawn threads to process
for i in range(0, 5):

t = ProcessThread?(pathqueue, resultqueue)
t.setDaemon(True)
t.start()

# spawn threads to print
t = PrintThread?(resultqueue)
t.setDaemon(True)
t.start()

# add paths to queue
for path in paths:

pathqueue.put(path)

# wait for queue to get empty
pathqueue.join()
resultqueue.join()
===

[zhangjr]

Productor-cosumer model is applied.

Productor has in- and out- queue.
Cosumer has in-queue.

Queue can support FIFO, LIFO, and Priority modes.

[zhangjr]

Changes in Thread.run()
===
try:

self.process

except:

break

===

[zhangjr]

Another possible solution. weakref+with

===
import weakref

class FooType?(object):

def init(self, id, parent):

self.id = id
self.parent = weakref.ref(parent)
#self.parent =parent
print 'child', self.id, 'new'

def del(self):

print 'child', self.id, 'del'

def exit(self, type, value, traceback):

print 'child', self.id, 'exit'

def enter(self):

print 'child', self.id, 'enter'

class BarType?(object):

def init(self, id):

self.id = id
print 'main', self.id, 'new'
with FooType?(id, self) as self.foo:

pass

def del(self):

print 'main', self.id, 'del'

b = BarType?(12)
===

[zhangjr]

The final solution:

try:
except:
finally: