[−][src]Struct wd_event::task_pool::TaskEntity
Implementations
impl TaskEntity
[src]
pub fn new(t: TaskPoolType, cache: usize) -> TaskEntity
[src]
pub fn init(&self)
[src]
pub async fn init_task_pool<'_>(&'_ self)
[src]
pub async fn worker(
receiver: Arc<SegQueue<Arc<dyn Task + Send + Sync + 'static>>>,
now: Arc<AtomicU32>,
status: Arc<AtomicBool>,
max: u32,
min: u32
)
[src]
receiver: Arc<SegQueue<Arc<dyn Task + Send + Sync + 'static>>>,
now: Arc<AtomicU32>,
status: Arc<AtomicBool>,
max: u32,
min: u32
)
pub fn make_worker(&self)
[src]
pub fn run(&self, f: Arc<dyn Task + Send + Sync + 'static>) -> usize
[src]
立即发送到执行队列,如果限定了max,则有可能造成堆积,导致内存暴增
pub async fn run_ease<'_>(&'_ self, f: Arc<dyn Task + Send + Sync + 'static>)
[src]
如果当前堆积任务过多超过预定闸值则缓解发送
pub fn close(&self)
[src]
关闭任务池并将已存在的任务执行完毕
Auto Trait Implementations
impl !RefUnwindSafe for TaskEntity
impl Send for TaskEntity
impl Sync for TaskEntity
impl Unpin for TaskEntity
impl !UnwindSafe for TaskEntity
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,
pub fn borrow_mut(&mut self) -> &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.
pub 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>,