Struct StealableTaskPool

pub struct StealableTaskPool<O: Default + 'static> { /* private fields */ }

可窃取的混合任务池

Implementations

impl<O: Default + 'static> StealableTaskPool<O>

pub fn new() -> Self

可窃取的快速工作者任务池

pub fn with( worker_size: usize, internal_queue_capacity: usize, weights: [u8; 2], interval: usize, ) -> Self

构建指定工作者任务池数量，工作者内部任务队列容量，工作者任务栈容量，任务队列的权重和整理间隔时长的可窃取的快速工作者任务池

Trait Implementations

impl<O: Default + 'static> AsyncTaskPool<O> for StealableTaskPool<O>

type Pool = StealableTaskPool<O>

fn get_thread_id(&self) -> usize

获取绑定的线程唯一id

fn len(&self) -> usize

获取当前异步任务池内任务数量

fn push(&self, task: Arc<AsyncTask<Self::Pool, O>>) -> Result<()>

将异步任务加入异步任务池

fn push_local(&self, task: Arc<AsyncTask<Self::Pool, O>>) -> Result<()>

将异步任务加入本地异步任务池

fn push_priority( &self, priority: usize, task: Arc<AsyncTask<Self::Pool, O>>, ) -> Result<()>

将指定了优先级的异步任务加入任务池

fn push_keep(&self, task: Arc<AsyncTask<Self::Pool, O>>) -> Result<()>

异步任务被唤醒时，将异步任务继续加入异步任务池

fn try_pop(&self) -> Option<Arc<AsyncTask<Self::Pool, O>>>

尝试从异步任务池中弹出一个异步任务

fn try_pop_all(&self) -> IntoIter<Arc<AsyncTask<Self::Pool, O>>>

尝试从异步任务池中弹出所有异步任务

fn get_thread_waker(&self) -> Option<&Arc<(AtomicBool, Mutex<()>, Condvar)>>

获取本地线程的唤醒器

impl<O: Default + 'static> AsyncTaskPoolExt<O> for StealableTaskPool<O>

fn worker_len(&self) -> usize

获取工作者的数量

fn clone_thread_waker(&self) -> Option<Arc<(AtomicBool, Mutex<()>, Condvar)>>

复制当前绑定本地线程的唤醒器

fn set_waits( &mut self, _waits: Arc<ArrayQueue<Arc<(AtomicBool, Mutex<()>, Condvar)>>>, )

设置待唤醒的工作者唤醒器队列

fn get_waits( &self, ) -> Option<&Arc<ArrayQueue<Arc<(AtomicBool, Mutex<()>, Condvar)>>>>

获取待唤醒的工作者唤醒器队列

fn idler_len(&self) -> usize

获取空闲的工作者的数量，这个数量大于0，表示可以新开线程来运行可分派的工作者

fn spawn_worker(&self) -> Option<usize>

分派一个空闲的工作者

fn buffer_len(&self) -> usize

获取缓冲区的任务数量，缓冲区任务是未分配给工作者的任务

fn set_thread_waker( &mut self, _thread_waker: Arc<(AtomicBool, Mutex<()>, Condvar)>, )

设置当前绑定本地线程的唤醒器

fn close_worker(&self)

关闭当前工作者

impl<O: Default + 'static> Default for StealableTaskPool<O>

fn default() -> Self

Returns the “default value” for a type.

impl<O: Default + 'static> Send for StealableTaskPool<O>

impl<O: Default + 'static> Sync for StealableTaskPool<O>