Page History
...
Code Block | ||||
---|---|---|---|---|
| ||||
from mpi4py import MPI comm = MPI.COMM_WORLD rank = comm.Get_rank() size = comm.Get_size() hostname = get_hostname() cpu_num = psutil.Process().cpu_num() print('rank:%02d cpu_num:%03d size:%02d' % (rank, cpu_num, size)) ranks = (0, 10, 20, 30, 40, 50, 60, 70) SAVE_FIGS = True SHOW_FIGS = False nevents = 100 arrts = np.zeros((nevents, size), dtype=np.float64) for nevt in range(nevents): dt_sec = time_consuming_algorithm() arrts[nevt,rank] = dt_sec # dt_sec = time()-t0_sec cpu_num = psutil.Process().cpu_num() if cpu_num >=16 and cpu_num <=23: print('rank:%02d cpu_num:%03d nevt:%03d time:%.6f CPU_NUM IN WEKA RANGE [16,23]' % (rank, cpu_num, nevt, dt_sec)) if nevt%10>0: continue print('rank:%02d cpu_num:%03d nevt:%03d time:%.6f' % (rank, cpu_num, nevt, dt_sec)) ... somme graphics for array arrts |
...
Overview
Content Tools