mindspore.runtime.StreamCtx

class mindspore.runtime.StreamCtx(ctx_stream)

Context-manager that selects a given stream.

All kernels queued within its context will be enqueued on a selected stream.

Parameters

ctx_stream (Stream) – selected stream. This manager is a no-op if it's None.

Raises

TypeError – If 'stream' is neither a mindspore.runtime.Stream nor a None.

Examples

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