Python 関数と入力キューを入力として受け取り、マルチプロセッシングを介してその入力を介してその関数をディスパッチするディスパッチ関数を記述したいマルチプロセッシングの使用例がありますか?
args
関数は厳密に共有されるわけではないため、渡すのが適切かどうかはわかりません。
import multiprocessing
def dispatch(queue, function):
while True:
if queue.empty():
return
current_project = queue.get()
function(current_project)
def letter_rip(projects_filename, function):
project_file = open(projects_filename, 'r')
projects = project_file.readlines()
project_file.close()
q = multiprocessing.Queue()
for project in projects:
q.put(project)
for i in xrange(0, 128):
p = multiprocessing.Process(target=dispatch, args=(q, ???function??? ))
p.start()