擅长:python、mysql、java
<p>最后是服务器错误,但我不知道是什么。在</p>
<p>在这里,我写了kugg的示例,其中包含信号量的释放,以便可以使用较低的PROCS_限制:</p>
<pre><code>from multiprocessing import *
PROCS_LIMIT = 2
semaphore_processes_limit = BoundedSemaphore(value=PROCS_LIMIT)
# Process
def process(word):
print(word)
semaphore_processes_limit.release()
return
# Starting searches
words = ["foo", "bar", "baz", "buz", "biz"]
procs = []
for word in words:
semaphore_processes_limit.acquire()
p = Process(target=process, args=(word,))
procs.append(p)
p.start()
# Wait for all worker processes to finish
for p in procs:
p.join()
</code></pre>