擅长:python、mysql、java
<p>您可以将<code>for</code>循环的主体提取到它自己的函数中,创建<a href="https://docs.python.org/3/library/multiprocessing.html#multiprocessing.pool.Pool" rel="nofollow noreferrer">a ^{<cd2>} object</a>,然后像这样调用<a href="https://docs.python.org/3/library/multiprocessing.html#multiprocessing.pool.Pool.map" rel="nofollow noreferrer">^{<cd3>}</a>(我使用了更具描述性的名称):</p>
<pre><code>import csv
import multiprocessing
def read_and_write_single_file(stem):
data = None
with open(stem, "r") as f:
# populate data somehow
csv_file = stem + ".csv"
with open(csv_file, "w", encoding="utf-8") as f:
w = csv.writer(f)
for row in data:
w.writerow(data)
if __name__ == "__main__":
pool = multiprocessing.Pool()
result = pool.map(read_and_write_single_file, get_list_of_files())
</code></pre>
<p>有关如何控制工人人数、每个工人的任务等,请参阅链接的文档</p>