Struct SingleTaskPool

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

单线程任务池

Implementations

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

pub fn new(weights: [u8; 2]) -> Self

构建指定权重的单线程任务池

Trait Implementations

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

type Pool = SingleTaskPool<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 SingleTaskPool<O>

fn set_thread_waker( &mut self, thread_waker: 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 worker_len(&self) -> usize

获取工作者的数量

fn buffer_len(&self) -> usize

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

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

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

fn close_worker(&self)

关闭当前工作者

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

fn default() -> Self

Returns the “default value” for a type.

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

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