我在这里是根据您的要求猜测的,因为原始问题尚不清楚。由于
os.listdir不能保证顺序,因此我假设您的“两个”功能实际上是相同的,您只需要同时对多个文件执行相同的过程。
以我的经验,最简单的方法是
Pool启动一个,为每个文件启动一个进程,然后等待。例如
import multiprocessingdef process(file): pass # do stuff to a filep = multiprocessing.Pool()for f in glob.glob(folder+"*.csv"): # launch a process for each file (ish). # The result will be approximately one process per CPU core available. p.apply_async(process, [f])p.close()p.join() # Wait for all child processes to close.



