Используя многопроцессорную обработку Python с разными случайными начальными числами для каждого процесса

Я хочу запустить несколько экземпляров симуляции параллельно, но с каждой симуляцией, имеющей свой собственный независимый набор данных.

В настоящее время я реализую это следующим образом:

P = mp.Pool(ncpus) # Generate pool of workers
for j in range(nrun): # Generate processes
    sim = MDF.Simulation(tstep, temp, time, writeout, boundaryxy, boundaryz, relax, insert, lat,savetemp)
    lattice = MDF.Lattice(tstep, temp, time, writeout, boundaryxy, boundaryz, relax, insert, lat, kb, ks, kbs, a, p, q, massL, randinit, initvel, parangle,scaletemp,savetemp)
    adatom1 = MDF.Adatom(tstep, temp, time, writeout, boundaryxy, boundaryz, relax, insert, lat, ra, massa, amorse, bmorse, r0, z0, name, lattice, samplerate,savetemp)        
    P.apply_async(run,(j,sim,lattice,adatom1),callback=After) # run simulation and ISF analysis in each process
P.close()
P.join() # start processes  

где sim , adatom1 и решетка - это объекты, переданные в функцию run который запускает моделирование.

Однако недавно я обнаружил, что каждая партия, которую я выполняю одновременно (то есть каждый ncpus исчерпывает общее nrun прогонов моделирования), дает точно такие же результаты.

Может кто-нибудь объяснить, как это исправить?

20
задан skrrgwasme 27 February 2015 в 22:18
поделиться