[−][src]Enum tantivy::Executor
Search executor whether search request are single thread or multithread.
We don't expose Rayon thread pool directly here for several reasons.
First dependency hell. It is not a good idea to expose the API of a dependency, knowing it might conflict with a different version used by the client. Second, we may stop using rayon in the future.
Variants
Single thread variant of an Executor
ThreadPool(ThreadPool)
Thread pool variant of an Executor
Implementations
impl Executor
[src]
pub fn single_thread() -> Executor
[src]
Creates an Executor that performs all task in the caller thread.
pub fn multi_thread(
num_threads: usize,
prefix: &'static str
) -> Result<Executor>
[src]
num_threads: usize,
prefix: &'static str
) -> Result<Executor>
Creates an Executor that dispatches the tasks in a thread pool.
pub fn map<A: Send, R: Send, AIterator: Iterator<Item = A>, F: Sized + Sync + Fn(A) -> Result<R>>(
&self,
f: F,
args: AIterator
) -> Result<Vec<R>>
[src]
&self,
f: F,
args: AIterator
) -> Result<Vec<R>>
Perform a map in the thread pool.
Regardless of the executor (SingleThread
or ThreadPool
), panics in the task
will propagate to the caller.
Auto Trait Implementations
impl !RefUnwindSafe for Executor
impl Send for Executor
impl Sync for Executor
impl Unpin for Executor
impl !UnwindSafe for Executor
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> Downcast for T where
T: Any,
[src]
T: Any,
fn into_any(self: Box<T>) -> Box<dyn Any + 'static>
[src]
fn into_any_rc(self: Rc<T>) -> Rc<dyn Any + 'static>
[src]
fn as_any(&self) -> &(dyn Any + 'static)
[src]
fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
[src]
impl<T> DowncastSync for T where
T: Send + Sync + Any,
[src]
T: Send + Sync + Any,
impl<T> Erased for T
[src]
impl<T> From<T> for T
[src]
impl<T> Fruit for T where
T: Send + Downcast,
[src]
T: Send + Downcast,
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<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,