Mikaela/Limnoria
1
0
Fork 0
mirror of https://github.com/Mikaela/Limnoria.git synced 2024-11-02 17:29:22 +01:00
Code Issues Projects Releases Wiki Activity

No one's using this WorkQueue crap; I didn't really mean for it to be committed.

Browse Source
This commit is contained in:
Jeremy Fincher 2004-08-04 04:50:59 +00:00
parent 9d3f572b71
commit 6dd8693daa
1 changed files with 0 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
src/structures.py
View File

@ -349,29 +349,4 @@ class TwoWayDictionary(dict):
dict.__delitem__(self, value) dict.__delitem__(self, value)
class WorkQueue(object):
def __init__(self, q=None, n=1):
if q is None:
q = Queue.Queue()
self.q = q
self.numberOfThreads = n
self.threads = []
for _ in xrange(n):
t = threading.Thread(target=self.target)
self.threads.append(t)
t.start()
def target(self):
while 1:
f = self.q.get()
if f is None:
self.q.put(None)
break
else:
f()
def enqueue(self, f):
self.q.put(f)
# vim:set shiftwidth=4 tabstop=8 expandtab textwidth=78: # vim:set shiftwidth=4 tabstop=8 expandtab textwidth=78: