mpi4py

1熱度

1回答

你可以看到herempi4py似乎已經定義了mprobe和improbe，但是，似乎沒有mrecv,Mrecv或任何其他類似的變化。我應該用什麼來接收信息？

0熱度

1回答

#mpiexec -n 3 python pass_dict.py from mpi4py import MPI import psycopg2 comm = MPI.COMM_WORLD rank = comm.Get_rank() size = comm.Get_size() tax_dict={} if rank == 0: tax_files=['2008','2

1熱度

1回答

mpi4py：在產生的進程之間進行通信

我有一個進程運行一個名爲t1.py的程序，它產生了3個其他進程，所有進程都運行t2.py。我想從生成的進程中以等級0向其他兩個衍生進程廣播一個值。但是，當調用bcast時，程序會阻塞。任何想法爲什麼發生這種情況我該如何解決它？ t1.py from mpi4py import MPI import sys sub_comm = MPI.COMM_SELF.Spawn(sys.executab

1熱度

1回答

獲取主要在任務服務器場中工作

我有一個小型測試代碼，充當任務服務器場，主進程將任務發送給從服務器。我想知道是否有一種簡單的方法，使主人從任務列表中分享工作。例如使用發送和接收來自主人自己，但我不確定這是否會完成乾淨。的代碼如下： ###!/usr/bin/env python from mpi4py import MPI import numpy import sys import os import time

0熱度

1回答

生成mpi4py進程後的屏障

我有一段代碼使用mpi4py來產生mpi exectuable的幾個實例。我希望代碼在這些進程完成時暫停，然後調用第二組相同的可執行文件。問題是，所有對mpi可執行文件的調用都會立即產生。似乎沒有辦法使用屏障來防止這種情況發生。有誰知道這是否正確，如果有的話，是否有人有一個明智的想法，以獲得我需要的結果。 #!/usr/bin/env python from mpi4py import MP

1熱度

2回答

如何使用mpi4py創建用於在節點之間傳遞的結構

我正在使用mpi4py來並行化我的代碼。我想在節點之間傳遞兩個數據，一個整數和一個實數。我也想使用數組和速度更快的函數Send和Recv。閱讀一些教程，似乎應該可以做到，但我找不到任何示例。以下是對沒有工作的簡單版本： import numpy from mpi4py import MPI comm = MPI.COMM_WORLD size = comm.Get_size() rank

1熱度

1回答

Suse系統上的mpi4py編譯錯誤

在我用服務器上的openmpi編譯mpi4py後，出現運行時錯誤。 OS: SuSe GCC: 4.8.5 OpenMPI: 1.10.1 HDF5: 1.8.11 mpi4py: 2.0.0 Python: 2.7.9 環境設置：我使用的virtualenv（服務器沒有管理員權限） (ENV) [email protected]:~/test> echo $PATH /opt/

0熱度

1回答

mpi4py只適用於mpiexec

我已經在一臺新的服務器上設置了mpi4py，但它並沒有工作。當我輸入mpi4py.MPI時，它崩潰。但是，如果我在mpiexec下執行同樣的操作，它就會起作用。在我的另一臺服務器和我的工作站上，兩種技術都可以正常工作我在新服務器上丟失了什麼？這裏是在新服務器上發生的事情： $ python -c 'from mpi4py import MPI; print("OK")' -----------

0熱度

1回答

爲什麼AllGather（）在具有不同迭代值的循環中失敗？

我編寫以下代碼AllGather（）實驗： from mpi4py import MPI comm = MPI.COMM_WORLD rank = comm.Get_rank() a = None if rank == 0: a = 2 if rank == 1: a = 3 z = 2 for i in range(0, a): z = comm.

1熱度

1回答

爲什麼Gather（）失敗，如果每個進程的根本身是自己的？

代碼： #mpiexec -n 2 python3 gather.py from mpi4py import MPI comm = MPI.COMM_WORLD rank = comm.Get_rank() a = 1 comm.barrier() b = comm.gather(a, root=rank) print("b:", b, rank) comm.barrier()