fn schedule(t: LightProc) {
    if let Err(err) = POOL.sender.try_send(t) {
        // We were not able to send to the channel without
        // blocking.
        POOL.sender.send(err.into_inner()).unwrap();
    }

    // Add up for every incoming scheduled task
    DYNAMIC_POOL_MANAGER.get().unwrap().increment_frequency();
}
/// Enqueues work, attempting to send to the thread pool in a
/// nonblocking way and spinning up needed amount of threads
/// based on the previous statistics without relying on
/// if there is not a thread ready to accept the work or not.
Enqueues work, attempting to send to the thread pool in a
nonblocking way and spinning up needed amount of threads
based on the previous statistics without relying on
if there is not a thread ready to accept the work or not.
Enqueues work attempting to send to the thread pool in a nonblocking way and spinning up needed amount of threads based on the previous statistics without relying on if there is not a thread ready to accept the work or not .
fn schedule(t: LightProc) {
    if let Err(err) = POOL.sender.try_send(t) {
        // We were not able to send to the channel without
        // blocking.
        POOL.sender.send(err.into_inner()).unwrap();
    }
    // Add up for every incoming scheduled task
    DYNAMIC_POOL_MANAGER.get().unwrap().increment_frequency();
}
fn schedule ( t : LightProc ) { if let Err ( err ) = POOL . sender . try_send ( t ) { // We were not able to send to the channel without // blocking. POOL . sender . send ( err . into_inner ( ) ) . unwrap ( ) ; } // Add up for every incoming scheduled task DYNAMIC_POOL_MANAGER . get ( ) . unwrap ( ) . increment_frequency ( ) ; }
Enqueues work, attempting to send to the thread pool in a
nonblocking way and spinning up needed amount of threads
based on the previous statistics without relying on
if there is not a thread ready to accept the work or not.
Enqueues work attempting to send to the thread pool in a nonblocking way and spinning up needed amount of threads based on the previous statistics without relying on if there is not a thread ready to accept the work or not .
t
LightProc
t
LightProc