mindspore.communication.comm_func.barrier
- mindspore.communication.comm_func.barrier(group=GlobalComm.WORLD_COMM_GROUP)[源代码]
同步通信域内的多个进程。进程调用到该算子后进入阻塞状态,直到通信域内所有进程调用到该算子, 进程被唤醒并继续执行。
- 参数:
group (str,可选) - 表示通信域。默认值:
GlobalComm.WORLD_COMM_GROUP
。
- 异常:
RuntimeError - 如果后端无效,或者分布式初始化失败。
- 支持平台:
Ascend
样例:
>>> from mindspore.communication import init >>> from mindspore.communication.comm_func import barrier >>> # Launch 2 processes. >>> init() >>> barrier()