pub struct Scope<'scope> { /* private fields */ }Expand description
Represents a fork-join scope which can be used to spawn any number of tasks.
See scope() for more information.
Implementations§
Source§impl<'scope> Scope<'scope>
impl<'scope> Scope<'scope>
Sourcepub fn spawn<BODY>(&self, body: BODY)
pub fn spawn<BODY>(&self, body: BODY)
Spawns a job into the fork-join scope self. This job will
execute sometime before the fork-join scope completes. The
job is specified as a closure, and this closure receives its
own reference to the scope self as argument. This can be
used to inject new jobs into self.
§Returns
Nothing. The spawned closures cannot pass back values to the caller directly, though they can write to local variables on the stack (if those variables outlive the scope) or communicate through shared channels.
(The intention is to eventually integrate with Rust futures to support spawns of functions that compute a value.)
§Examples
let mut value_a = None;
let mut value_b = None;
let mut value_c = None;
rayon::scope(|s| {
s.spawn(|s1| {
// ^ this is the same scope as `s`; this handle `s1`
// is intended for use by the spawned task,
// since scope handles cannot cross thread boundaries.
value_a = Some(22);
// the scope `s` will not end until all these tasks are done
s1.spawn(|_| {
value_b = Some(44);
});
});
s.spawn(|_| {
value_c = Some(66);
});
});
assert_eq!(value_a, Some(22));
assert_eq!(value_b, Some(44));
assert_eq!(value_c, Some(66));§See also
The scope function has more extensive documentation about
task spawning.
Sourcepub fn spawn_broadcast<BODY>(&self, body: BODY)
pub fn spawn_broadcast<BODY>(&self, body: BODY)
Spawns a job into every thread of the fork-join scope self. This job will
execute on each thread sometime before the fork-join scope completes. The
job is specified as a closure, and this closure receives its own reference
to the scope self as argument, as well as a BroadcastContext.
Trait Implementations§
Auto Trait Implementations§
impl<'scope> !Freeze for Scope<'scope>
impl<'scope> !RefUnwindSafe for Scope<'scope>
impl<'scope> Send for Scope<'scope>
impl<'scope> Sync for Scope<'scope>
impl<'scope> Unpin for Scope<'scope>
impl<'scope> !UnwindSafe for Scope<'scope>
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§impl<T> Pointable for T
impl<T> Pointable for T
Layout§
Note: Most layout information is completely unstable and may even differ between compilations. The only exception is types with certain repr(...) attributes. Please see the Rust Reference's “Type Layout” chapter for details on type layout guarantees.
Size: 48 bytes