mindspore.hal.synchronize

mindspore.hal.synchronize()[source]

Synchronize all streams on current device.(Each MindSpore process only occupies one device)

Examples

>>> import mindspore as ms
>>> import numpy as np
>>> from mindspore import Tensor, ops
>>> a = Tensor(np.ones([1024, 2048]), ms.float32)
>>> b = Tensor(np.ones([2048, 4096]), ms.float32)
>>> s1 = ms.hal.Stream()
>>> with ms.hal.StreamCtx(s1):
...     c = ops.matmul(a, b)
>>> ms.hal.synchronize()
>>> assert s1.query()