高并發(fā)中Poll和Epoll以及Future的概念是什么，針對這個問題，這篇文章詳細(xì)介紹了相對應(yīng)的分析和解答，希望可以幫助更多想解決這個問題的小伙伴找到更簡單易行的方法。

網(wǎng)站建設(shè)哪家好，找成都創(chuàng)新互聯(lián)！專注于網(wǎng)頁設(shè)計、網(wǎng)站建設(shè)、微信開發(fā)、小程序設(shè)計、集團(tuán)企業(yè)網(wǎng)站建設(shè)等服務(wù)項目。為回饋新老客戶創(chuàng)新互聯(lián)還提供了柳河免費建站歡迎大家使用！

高并發(fā)中有幾個重要概念：Poll、Epoll、Future。

Future并不是一個主流的實現(xiàn)，但是Future與Poll的概念又是如此重要，我們必須放在開頭來講，因此這里先將重心放在Rust身上，由于Rust與Go、Java相比對于Future實現(xiàn)比較完整，特性支持也徹底。因此下面的代碼均以Rust為例。

簡單來講Future不是一個值，而是一種值類型，一種在未來才能得到的值類型。Future對象必須實現(xiàn)Rust標(biāo)準(zhǔn)庫中的std::future:: future接口。Future的輸出Output是Future完成后才能生成的值。在Rust中Future通過管理器調(diào)用Future::poll來推動Future的運算。Future本質(zhì)上是一個狀態(tài)機(jī)，而且可以嵌套使用，我們來看一下面這個例子，在main函數(shù)中，我們實例化MainFuture并調(diào)用.await，而MainFuture除了在幾個狀態(tài)之間遷移以外，還會調(diào)用一個Delay的Future，從而實現(xiàn)Future的嵌套。

MainFuture以State0狀態(tài)做為初始狀態(tài)。當(dāng)調(diào)度器調(diào)用poll方法時，MainFuture會嘗試盡可能地提升其狀態(tài)。如果future完成，則返回Poll::Ready，如果MainFuture沒有完成，則是由于它等待的DelayFuture沒有達(dá)到Ready狀態(tài)，那么此時返回Pending。調(diào)度器收到Pending結(jié)果，會將這個MainFuture重新放回待調(diào)度的隊列當(dāng)中，稍后會再度調(diào)用Poll方法來推進(jìn)Future的執(zhí)行。具體如下：

use std::future::Future;
use std::pin::Pin;
usestd::task::{Context, Poll};
usestd::time::{Duration, Instant};
 
struct Delay {
    when: Instant,
}
impl Future forDelay {
    type Output = &'static str;
 
    fn poll(self: Pin<&mut Self>, cx:&mut Context<'_>)
        -> Poll<&'static str>
    {
        if Instant::now() >= self.when {
            println!("Hello world");
            Poll::Ready("done")
        } else {
          
            cx.waker().wake_by_ref();
            Poll::Pending
        }
    }
}
enum MainFuture {
   
    State0,
    State1(Delay),
    Terminated,
}
impl Future forMainFuture {
    type Output = ();
 
    fn poll(mut self: Pin<&mut Self>,cx: &mut Context<'_>)
        -> Poll<()>
    {
        use MainFuture::*;
     
        loop {
            match *self {
                State0 => {
                    let when = Instant::now() +
                        Duration::from_millis(1);
                    let future = Delay { when};
                    println!("initstatus");
                    *self = State1(future);
                }
                State1(ref mut my_future) =>{
                    matchPin::new(my_future).poll(cx) {
                        Poll::Ready(out) =>{
                            assert_eq!(out,"done");
                           println!("delay finished this future is ready");
                            *self = Terminated;
                            returnPoll::Ready(());
                        }
                        Poll::Pending => {
                            println!("notready");
                            returnPoll::Pending;
                        }
                    }
                }
                Terminated => {
                    panic!("future polledafter completion")
                }
            }
        }
    }
}
#[tokio::main]
async fn main() {
    let when = Instant::now() +Duration::from_millis(10);
  
    let mainFuture=MainFuture::State0;
    mainFuture.await;
  
}

關(guān)于高并發(fā)中Poll和Epoll以及Future的概念是什么問題的解答就分享到這里了，希望以上內(nèi)容可以對大家有一定的幫助，如果你還有很多疑惑沒有解開，可以關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道了解更多相關(guān)知識。