[−][src]Struct futures::executor::LocalPool
A single-threaded task pool for polling futures to completion.
This executor allows you to multiplex any number of tasks onto a single thread. It's appropriate to poll strictly I/O-bound futures that do very little work in between I/O actions.
To get a handle to the pool that implements
Spawn
, use the
spawner()
method. Because the executor is
single-threaded, it supports a special form of task spawning for non-Send
futures, via spawn_local_obj
.
Methods
impl LocalPool
[src]
impl LocalPool
pub fn new() -> LocalPool
[src]
pub fn new() -> LocalPool
Create a new, empty pool of tasks.
pub fn spawner(&self) -> LocalSpawner
[src]
pub fn spawner(&self) -> LocalSpawner
Get a clonable handle to the pool as a [Spawn
].
pub fn run(&mut self)
[src]
pub fn run(&mut self)
Run all tasks in the pool to completion.
The given spawner, spawn
, is used as the default spawner for any
newly-spawned tasks. You can route these additional tasks back into
the LocalPool
by using its spawner handle:
use futures::executor::LocalPool; let mut pool = LocalPool::new(); // ... spawn some initial tasks using `spawn.spawn()` or `spawn.spawn_local()` // run *all* tasks in the pool to completion, including any newly-spawned ones. pool.run();
The function will block the calling thread until all tasks in the pool are complete, including any spawned while running existing tasks.
pub fn run_until<F>(&mut self, future: F) -> <F as Future>::Output where
F: Future,
[src]
pub fn run_until<F>(&mut self, future: F) -> <F as Future>::Output where
F: Future,
Runs all the tasks in the pool until the given future completes.
The given spawner, spawn
, is used as the default spawner for any
newly-spawned tasks. You can route these additional tasks back into
the LocalPool
by using its spawner handle:
#![feature(pin, arbitrary_self_types, futures_api)] use futures::executor::LocalPool; use futures::future::ready; let mut pool = LocalPool::new(); // run tasks in the pool until `my_app` completes, by default spawning // further tasks back onto the pool pool.run_until(my_app);
The function will block the calling thread only until the future f
completes; there may still be incomplete tasks in the pool, which will
be inert after the call completes, but can continue with further use of
run
or run_until
. While the function is running, however, all tasks
in the pool will try to make progress.
Trait Implementations
Auto Trait Implementations
Blanket Implementations
impl<T, U> Into for T where
U: From<T>,
[src]
impl<T, U> Into for T where
U: From<T>,
impl<T> From for T
[src]
impl<T> From for T
impl<T, U> TryFrom for T where
T: From<U>,
[src]
impl<T, U> TryFrom for T where
T: From<U>,
type Error = !
try_from
)The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
try_from
)Performs the conversion.
impl<T> Borrow for T where
T: ?Sized,
[src]
impl<T> Borrow for T where
T: ?Sized,
impl<T> Any for T where
T: 'static + ?Sized,
[src]
impl<T> Any for T where
T: 'static + ?Sized,
fn get_type_id(&self) -> TypeId
[src]
fn get_type_id(&self) -> TypeId
🔬 This is a nightly-only experimental API. (get_type_id
)
this method will likely be replaced by an associated static
Gets the TypeId
of self
. Read more
impl<T> BorrowMut for T where
T: ?Sized,
[src]
impl<T> BorrowMut for T where
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
impl<T, U> TryInto for T where
U: TryFrom<T>,
[src]
impl<T, U> TryInto for T where
U: TryFrom<T>,