Struct opencv::core::Stream

source ·
pub struct Stream { /* private fields */ }
Expand description

This class encapsulates a queue of asynchronous calls.

Note: Currently, you may face problems if an operation is enqueued twice with different data. Some functions use the constant GPU memory, and next call may update the memory before the previous one has been finished. But calling different operations asynchronously is safe because each operation has its own constant buffer. Memory copy/upload/download/set operations to the buffers you hold are also safe.

Note: The Stream class is not thread-safe. Please use different Stream objects for different CPU threads.

void thread1()
{
   cv::cuda::Stream stream1;
   cv::cuda::func1(..., stream1);
}
 
void thread2()
{
   cv::cuda::Stream stream2;
   cv::cuda::func2(..., stream2);
}

Note: By default all CUDA routines are launched in Stream::Null() object, if the stream is not specified by user. In multi-threading environment the stream objects must be passed explicitly (see previous note).

Implementations§

source§

impl Stream

source

pub fn default() -> Result<Stream>

creates a new asynchronous stream

source

pub fn new(allocator: &Ptr<GpuMat_Allocator>) -> Result<Stream>

creates a new asynchronous stream with custom allocator

source

pub fn new_1(cuda_flags: size_t) -> Result<Stream>

creates a new Stream using the cudaFlags argument to determine the behaviors of the stream

Note: The cudaFlags parameter is passed to the underlying api cudaStreamCreateWithFlags() and supports the same parameter values.

   // creates an OpenCV cuda::Stream that manages an asynchronous, non-blocking,
   // non-default CUDA stream
   cv::cuda::Stream cvStream(cudaStreamNonBlocking);
source

pub fn null() -> Result<Stream>

return Stream object for default CUDA stream

Trait Implementations§

source§

impl Boxed for Stream

source§

unsafe fn from_raw(ptr: *mut c_void) -> Self

Wrap the specified raw pointer Read more
source§

fn into_raw(self) -> *mut c_void

Return an the underlying raw pointer while consuming this wrapper. Read more
source§

fn as_raw(&self) -> *const c_void

Return the underlying raw pointer. Read more
source§

fn as_raw_mut(&mut self) -> *mut c_void

Return the underlying mutable raw pointer Read more
source§

impl Debug for Stream

source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more
source§

impl Drop for Stream

source§

fn drop(&mut self)

Executes the destructor for this type. Read more
source§

impl StreamTrait for Stream

source§

fn as_raw_mut_Stream(&mut self) -> *mut c_void

source§

fn wait_for_completion(&mut self) -> Result<()>

Blocks the current CPU thread until all operations in the stream are complete.
source§

fn wait_event(&mut self, event: &Event) -> Result<()>

Makes a compute stream wait on an event.
source§

fn enqueue_host_callback( &mut self, callback: Stream_StreamCallback ) -> Result<()>

Adds a callback to be called on the host after all currently enqueued items in the stream have completed. Read more
source§

impl StreamTraitConst for Stream

source§

fn as_raw_Stream(&self) -> *const c_void

source§

fn query_if_complete(&self) -> Result<bool>

Returns true if the current stream queue is finished. Otherwise, it returns false.
source§

fn cuda_ptr(&self) -> Result<*mut c_void>

return Pointer to CUDA stream
source§

impl Send for Stream

Auto Trait Implementations§

Blanket Implementations§

source§

impl<T> Any for Twhere T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Borrow<T> for Twhere T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for Twhere T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T, U> Into<U> for Twhere U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.