Struct tokio::runtime::TaskExecutor
source · pub struct TaskExecutor { /* private fields */ }
Expand description
Executes futures on the runtime
All futures spawned using this executor will be submitted to the associated Runtime’s executor. This executor is usually a thread pool.
For more details, see the module level documentation.
Implementations§
source§impl TaskExecutor
impl TaskExecutor
sourcepub fn spawn<F>(&self, future: F)where
F: Future<Item = (), Error = ()> + Send + 'static,
pub fn spawn<F>(&self, future: F)where
F: Future<Item = (), Error = ()> + Send + 'static,
Spawn a future onto the Tokio runtime.
This spawns the given future onto the runtime’s executor, usually a thread pool. The thread pool is then responsible for polling the future until it completes.
See module level documentation for more details.
Examples
use tokio::runtime::Runtime;
// Create the runtime
let mut rt = Runtime::new().unwrap();
let executor = rt.executor();
// Spawn a future onto the runtime
executor.spawn(future::lazy(|| {
println!("now running on a worker thread");
Ok(())
}));
Panics
This function panics if the spawn fails. Failure occurs if the executor is currently at capacity and is unable to spawn a new future.
Trait Implementations§
source§impl Clone for TaskExecutor
impl Clone for TaskExecutor
source§fn clone(&self) -> TaskExecutor
fn clone(&self) -> TaskExecutor
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read more