[−][src]Struct mpmc_scheduler::Controller
The Controller is a non-producing handle to the scheduler. It allows creation of new channels as well as clearing of queues.
Methods
impl<K, V, R> Controller<K, V, R> where
K: Sync + Send + Hash + Eq,
V: Sync + Send + 'static,
R: 'static,
[src]
K: Sync + Send + Hash + Eq,
V: Sync + Send + 'static,
R: 'static,
pub fn channel(&self, key: K, bound: usize) -> Sender<V>
[src]
Create a new channel, returns the producer site. See below for bound. May block if clearing or scheduling tick is currently running.
Bound
Is the next power of two for the handed value
pub fn cancel_channel(&self, key: &K) -> Result<(), ()>
[src]
Clear queue for specific channel & running jobs if supported.
May block if channel
is called or a schedule is running.
Note that for a queue with bounds n, it has a O(n) worst case complexity.
Returns Err if the specified channel is invalid.
pub fn gc(&self)
[src]
Manually trigger schedule. Normaly not required but if you should drop a lot of channels and don't insert/complete a job in the next time, you may call this.
pub fn set_worker_max(&self, max_workers: usize)
[src]
Change maximum amount of workers.
Takes effect on next schedule.
pub fn get_worker_max(&self) -> usize
[src]
Returns currently set max amount of workers.
Trait Implementations
impl<K: Clone, V: Clone, R: Clone> Clone for Controller<K, V, R> where
K: Sync + Send + Hash + Eq,
V: Sync + Send + 'static,
R: 'static,
[src]
K: Sync + Send + Hash + Eq,
V: Sync + Send + 'static,
R: 'static,
fn clone(&self) -> Controller<K, V, R>
[src]
fn clone_from(&mut self, source: &Self)
1.0.0[src]
Performs copy-assignment from source
. Read more
Auto Trait Implementations
impl<K, V, R> Send for Controller<K, V, R>
impl<K, V, R> Sync for Controller<K, V, R>
Blanket Implementations
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
fn to_owned(&self) -> T
[src]
fn clone_into(&self, target: &mut T)
[src]
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,