Switched the order of actions, so that the explanation flows better
This commit is contained in:
@@ -23,16 +23,16 @@ def process_words():
|
|||||||
word_freqs[word] = 1
|
word_freqs[word] = 1
|
||||||
freq_space.put(word_freqs)
|
freq_space.put(word_freqs)
|
||||||
|
|
||||||
|
# Let's have this thread populate the word space
|
||||||
|
for word in re.findall('[a-z]{2,}', open(sys.argv[1]).read().lower()):
|
||||||
|
word_space.put(word)
|
||||||
|
|
||||||
# Let's create the workers and launch them at their jobs
|
# Let's create the workers and launch them at their jobs
|
||||||
workers = []
|
workers = []
|
||||||
for i in range(5):
|
for i in range(5):
|
||||||
workers.append(threading.Thread(target = process_words))
|
workers.append(threading.Thread(target = process_words))
|
||||||
[t.start() for t in workers]
|
[t.start() for t in workers]
|
||||||
|
|
||||||
# Let's have this thread populate the word space
|
|
||||||
for word in re.findall('[a-z]{2,}', open(sys.argv[1]).read().lower()):
|
|
||||||
word_space.put(word)
|
|
||||||
|
|
||||||
# Let's wait for the workers to finish
|
# Let's wait for the workers to finish
|
||||||
[t.join() for t in workers]
|
[t.join() for t in workers]
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user