Struct ocl::async::FutureGuard

pub struct FutureGuard<V, G>
where
    G: OrderGuard<V>,
{ /* private fields */ }

A future that resolves to a read or write guard after ensuring that the data being guarded is appropriately locked during the execution of an OpenCL command.

1. Waits until both an exclusive data lock can be obtained and all prerequisite OpenCL commands have completed.
2. Triggers an OpenCL command, remaining locked while the command executes.
3. Returns a guard which provides exclusive (write) or shared (read) access to the locked data.

Implementations

impl<V, G> FutureGuard<V, G>

where G: OrderGuard<V>,

pub fn set_lock_wait_events<L: Into<EventList>>(&mut self, wait_events: L)

Sets an event wait list.

Setting a wait list will cause this FutureGuard to wait until contained events have their status set to complete before obtaining a lock on the guarded internal value.

[UNSTABLE]: This method may be renamed or otherwise changed at any time.

pub fn ewait_lock<L: Into<EventList>>(self, wait_events: L) -> FutureGuard<V, G>

Sets an event wait list.

See ::set_lock_wait_events.

[UNSTABLE]: This method may be renamed or otherwise changed at any time.

pub fn create_lock_event<C: ClContextPtr>( &mut self, context: C ) -> OclResult<&Event>

Creates an event which will be triggered when a lock is obtained on the guarded internal value.

The returned event can be added to the wait list of subsequent OpenCL commands with the expectation that when all preceding futures are complete, the event will automatically be ‘triggered’ by having its status set to complete, causing those commands to execute. This can be used to inject host side code in amongst OpenCL commands without thread blocking or extra delays of any kind.

pub fn enew_lock<C, En>(self, context: C, enew: En) -> FutureGuard<V, G>

where C: ClContextPtr, En: ClNullEventPtr,

Creates an event which will be triggered when a lock is obtained on the guarded internal value.

enew must be an empty (null) event or event list.

See ::create_lock_event

Panics

Panics if there is an error creating the lock event.

[UNSTABLE]: This method may be renamed or otherwise changed at any time.

pub fn set_command_wait_event(&mut self, command_event: Event)

Sets a command completion wait event.

command_event must be an event created by enqueuing an OpenCL command which interacts (reads/writes) with the data associated with this FutureGuard.

If the command completion event is specified, this FutureGuard will “suffix” itself with an additional future that will wait until the command completes before resolving.

Not specifying a command completion event will cause this FutureGuard to resolve into an OrderGuard immediately after the lock is obtained (indicated by the optionally created lock event).

[UNSTABLE]: This method may be renamed or otherwise changed at any time.

pub fn ewait_command(self, command_event: Event) -> FutureGuard<V, G>

Sets a command completion wait event.

See ::set_command_wait_event.

[UNSTABLE]: This method may be renamed or otherwise changed at any time.

pub fn create_release_event<C: ClContextPtr>( &mut self, context: C ) -> OclResult<&Event>

Creates an event which will be triggered after this future resolves and the ensuing OrderGuard is dropped or manually released.

The returned event can be added to the wait list of subsequent OpenCL commands with the expectation that when all preceding futures are complete, the event will automatically be ‘triggered’ by having its status set to complete, causing those commands to execute. This can be used to inject host side code in amongst OpenCL commands without thread blocking or extra delays of any kind.

pub fn enew_release<C, En>(self, context: C, enew: En) -> FutureGuard<V, G>

where C: ClContextPtr, En: ClNullEventPtr,

Creates an event which will be triggered after this future resolves and the ensuing OrderGuard is dropped or manually released.

enew must be an empty (null) event or event list.

See ::create_release_event.

Panics

Panics if there is an error creating the release event.

[UNSTABLE]: This method may be renamed or otherwise changed at any time.

pub fn lock_event(&self) -> Option<&Event>

Returns a reference to the event previously created with ::create_lock_event or ::enew_lock which will trigger (be completed) when the wait events are complete and the lock is locked.

pub fn release_event(&self) -> Option<&Event>

Returns a reference to the event previously created with ::create_release_event or ::enew_release which will trigger (be completed) when a lock is obtained on the guarded internal value.

pub fn wait(self) -> OclResult<G>

Blocks the current thread until the OpenCL command is complete and an appropriate lock can be obtained on the underlying data.

pub fn as_ptr(&self) -> *const V

Returns a mutable pointer to the data contained within the internal value, bypassing all locks and protections.

Panics

This future must not have already resolved into a guard.

pub fn as_mut_ptr(&self) -> *mut V

Returns a mutable pointer to the data contained within the internal value, bypassing all locks and protections.

Panics

This future must not have already resolved into a guard.

pub fn order_lock(&self) -> &OrderLock<V>

Returns a reference to the OrderLock used to create this future.

impl<V> FutureGuard<V, ReadGuard<V>>

pub fn upgrade_after_command(self) -> FutureGuard<V, WriteGuard<V>>

Trait Implementations

impl<V: Debug, G> Debug for FutureGuard<V, G>

where G: OrderGuard<V> + Debug,

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

Formats the value using the given formatter.

impl<V, G> Drop for FutureGuard<V, G>

where G: OrderGuard<V>,

fn drop(&mut self)

Drops this FutureGuard.

Blocks the current thread until the command associated with this FutureGuard (represented by the command completion event) completes. This ensures that the underlying value is not dropped before the command completes (which would cause obvious problems).

future_guard_drop_panic Feature

If the future_guard_drop_panic feature is enabled, dropping a FutureGuard before it is polled will cause a panic.

impl<'d, T> From<FutureGuard<Vec<T>, ReadGuard<Vec<T>>>> for WriteSrc<'d, T>

where T: OclPrm,

fn from(reader: FutureReadGuard<Vec<T>>) -> WriteSrc<'d, T>

Converts to this type from the input type.

impl<V, G> Future for FutureGuard<V, G>

where G: OrderGuard<V>,

type Item = G

The type of value that this future will resolved with if it is successful.

type Error = Error

The type of error that this future will resolve with if it fails in a normal fashion.

fn poll(&mut self) -> Poll<Self::Item, Self::Error>

Query this future to see if its value has become available, registering interest if it is not.

fn wait(self) -> Result<Self::Item, Self::Error>

where Self: Sized,

Block the current thread until this future is resolved.

fn map<F, U>(self, f: F) -> Map<Self, F>

where F: FnOnce(Self::Item) -> U, Self: Sized,

Map this future’s result to a different type, returning a new future of the resulting type.

fn map_err<F, E>(self, f: F) -> MapErr<Self, F>

where F: FnOnce(Self::Error) -> E, Self: Sized,

Map this future’s error to a different error, returning a new future.

fn from_err<E>(self) -> FromErr<Self, E>

where E: From<Self::Error>, Self: Sized,

Map this future’s error to any error implementing From for this future’s Error, returning a new future.

fn then<F, B>(self, f: F) -> Then<Self, B, F>

where F: FnOnce(Result<Self::Item, Self::Error>) -> B, B: IntoFuture, Self: Sized,

Chain on a computation for when a future finished, passing the result of the future to the provided closure f.

fn and_then<F, B>(self, f: F) -> AndThen<Self, B, F>

where F: FnOnce(Self::Item) -> B, B: IntoFuture<Error = Self::Error>, Self: Sized,

Execute another future after this one has resolved successfully.

fn or_else<F, B>(self, f: F) -> OrElse<Self, B, F>

where F: FnOnce(Self::Error) -> B, B: IntoFuture<Item = Self::Item>, Self: Sized,

Execute another future if this one resolves with an error.

fn select<B>(self, other: B) -> Select<Self, <B as IntoFuture>::Future>

where B: IntoFuture<Item = Self::Item, Error = Self::Error>, Self: Sized,

Waits for either one of two futures to complete.

fn select2<B>(self, other: B) -> Select2<Self, <B as IntoFuture>::Future>

where B: IntoFuture, Self: Sized,

Waits for either one of two differently-typed futures to complete.

fn join<B>(self, other: B) -> Join<Self, <B as IntoFuture>::Future>

where B: IntoFuture<Error = Self::Error>, Self: Sized,

Joins the result of two futures, waiting for them both to complete.

fn join3<B, C>( self, b: B, c: C ) -> Join3<Self, <B as IntoFuture>::Future, <C as IntoFuture>::Future>

where B: IntoFuture<Error = Self::Error>, C: IntoFuture<Error = Self::Error>, Self: Sized,

Same as join, but with more futures.

fn join4<B, C, D>( self, b: B, c: C, d: D ) -> Join4<Self, <B as IntoFuture>::Future, <C as IntoFuture>::Future, <D as IntoFuture>::Future>

where B: IntoFuture<Error = Self::Error>, C: IntoFuture<Error = Self::Error>, D: IntoFuture<Error = Self::Error>, Self: Sized,

Same as join, but with more futures.

fn join5<B, C, D, E>( self, b: B, c: C, d: D, e: E ) -> Join5<Self, <B as IntoFuture>::Future, <C as IntoFuture>::Future, <D as IntoFuture>::Future, <E as IntoFuture>::Future>

where B: IntoFuture<Error = Self::Error>, C: IntoFuture<Error = Self::Error>, D: IntoFuture<Error = Self::Error>, E: IntoFuture<Error = Self::Error>, Self: Sized,

Same as join, but with more futures.

fn into_stream(self) -> IntoStream<Self>

where Self: Sized,

Convert this future into a single element stream.

fn fuse(self) -> Fuse<Self>

where Self: Sized,

Fuse a future such that poll will never again be called once it has completed.

fn inspect<F>(self, f: F) -> Inspect<Self, F>

where F: FnOnce(&Self::Item), Self: Sized,

Do something with the item of a future, passing it on.

fn shared(self) -> Shared<Self>

where Self: Sized,

Create a cloneable handle to this future where all handles will resolve to the same result.