亚洲最大看欧美片,亚洲图揄拍自拍另类图片,欧美精品v国产精品v呦,日本在线精品视频免费

  • 站長資訊網(wǎng)
    最全最豐富的資訊網(wǎng)站

    Java的NIO以及線程并發(fā)

    NIO出現(xiàn)后,好像讓java的程序員有了楊眉吐氣的機會,怎么個吐氣法,當(dāng)時大家是個什么感受,俺是不知道,因為當(dāng)時俺不搞java,對java的認(rèn)識有限。

    AD:

      一、NIO的出現(xiàn)

      NIO是JDK1.4里面才出現(xiàn)的東東,他給大家?guī)淼淖畲蠛锰幨钱惒絪ocket。其它file,pipe暫時就不多談了。

      在JDK1.4出現(xiàn)之前,如果你需要編寫一個Java服務(wù)器,為了實現(xiàn)異步操作,你必須為每個連接請求生成一個Java線程,當(dāng)連接請求很多時,線程的調(diào)度,上下文切換,所付出的代價是非常昂貴,而且由于Java是跨平臺的,各個平臺對線程的支持并不相同,性能也不相同,因此傳統(tǒng)的Java服務(wù)器編程架構(gòu)是低效的且代價貴,dl大俠寫了個util.concurrent包后,總算是減輕了線程調(diào)度給java程序員帶來的痛苦,但是相比之與C、C++寫出來的服務(wù)器,java服務(wù)器在性能要求很高的情況下,基本上沒有什么競爭力,甚至是入圍的權(quán)利的都沒有。

      二、異步socket的實現(xiàn)

      NIO出現(xiàn)后,好像讓java的程序員有了楊眉吐氣的機會,怎么個吐氣法,當(dāng)時大家是個什么感受,俺是不知道,因為當(dāng)時俺不搞java,對java的認(rèn)識有限。

      NIO是一個基于事件的IO架構(gòu),最基本的思想就是:有事件我通知你,你再去做你的事情,沒事件時你大可以節(jié)約大把時間去做其它任何事情。而且NIO的主線程only
      one,不像傳統(tǒng)的模型,需要N個線程去,也減輕了JVM的工作量,使得JVM處理任務(wù)時顯得更加高效。

      剛開始接觸NIO時,被N層的Channel架構(gòu)、網(wǎng)上鋪天蓋地的好評給鎮(zhèn)住了,想想也應(yīng)當(dāng)是個很成熟的產(chǎn)品了,網(wǎng)上資料這么多,抄一抄Jetty、Tomcat以及其它一些牛B的源代碼,基本上就能搞定了,此時沒有想到大家受同步的影響這么深,也沒有想到連最基本的異步概念都沒有搞清楚就去寫代碼,搞出一堆的問題來(這是后話,后面再說)。

      現(xiàn)在研究了NIO以后,發(fā)現(xiàn)NIO實際上在Java中做的工作是很簡單,就是將事件進行收集和分發(fā),我們結(jié)合一個經(jīng)典的調(diào)用例子來說明這個問題,我就不從NIO的基本使用說起了,大家可以查其它的資料,網(wǎng)上一大把。
      當(dāng)Channel注冊至Selector以后,我們的最經(jīng)典的調(diào)用方法,是這樣子的。

                                                       
      1. while(somecondition)
      2. {
      3. int n = selector.select(TIMEOUT);
      4. if(n == 0) continue;
      5. for (Iterator iter = selector.selectedKeys().iterator(); iter.hasNext();)
      6. {
      7. if (key.isAcceptable())
      8. doAcceptable(key);
      9. if (key.isConnectable())
      10. doConnectable(key);
      11. if (key.isValid() && key.isReadable())
      12. doReadable(key);
      13. if (key.isValid() && key.isWritable())
      14. doWritable(key);
      15. iter.remove();
      16. }
      17. }
       

      這只是個小例子啊,什么異常我就懶得抓了。

      nio中取得事件通知,就是在selector的select事件中完成的,在selector事件時有一個線程,這個線程具體的處理簡單點說就是:向操作系統(tǒng)詢問,selector中注冊的Channel&&SelectionKey的偶對各種事件是否有發(fā)生,如果有則添加到selector的selectedKeys屬性Set中去,并返回本次有多少個感興趣的事情發(fā)生。程序員發(fā)現(xiàn)這個值>0,表示有事件發(fā)生,馬上迭代selectedKeys中的SelectionKey,根據(jù)Key中的表示的事件,來做相應(yīng)的處理。

      實際上,這段說明表明了異步socket的核心,即異步socket不過是將多個socket的調(diào)度(或者還有他們的線程調(diào)度)全部交給操作系統(tǒng)自己去完成,異步的核心Selector,不過是將這些調(diào)度收集、分發(fā)而已。因為操作系統(tǒng)的socket、線程調(diào)度再咋D也比你JVM中要強,效率也高。

      而且就算jvm做的和操作系統(tǒng)一樣好,性能一樣高(當(dāng)然這是不現(xiàn)實的),使用異步socket你至少也節(jié)約了一半的系統(tǒng)消耗,想想假定操作系統(tǒng)本身也是使用線程來維護N個socket連接,在傳統(tǒng)的java編程中,你還必須為這些socket還多起一個java線程,那至少是2N個線程,現(xiàn)在只需要N+1。在高并發(fā)的情況下,你自己去想吧。

      懂了這個道理,異步socket也就好寫了,也不會搞得思路混亂了。

      三、 異步Socket中應(yīng)當(dāng)注意的事情

      1. 讀

      異步socket最基本的理念就是事件通知,前面也說了,有事件通知你了,你才該做你應(yīng)當(dāng)做的事情。在異步socket中當(dāng)注冊了一個OP_READ事件后,你就等著Selector通知你吧,如果沒有通知你,你在家睡大覺都行。
      在這里,我們有人出現(xiàn)的錯誤就是受同步的影響,自己去主動讀,而且還搞出了多線程,如果仔細(xì)考慮一下,就不會出現(xiàn)這個問題了。同步socket中,調(diào)用read方法讀取IO中的數(shù)據(jù)時,通常情況下如果沒有數(shù)據(jù)read方法會阻塞,且是同步的,所以當(dāng)多個線程同時訪問時,read方法是線程安全的。

      而在異步下就不同,異步是不會阻塞的,有什么就返回什么,你主動去讀,只要有數(shù)據(jù),你就可以拿走,在多線程的情況下,也許你是想讓第一個線程讀取,but此時來數(shù)據(jù)時正好是線程2讀到了,那線程2就高高興興的拿去,而線程1還在苦苦等待,這樣導(dǎo)致數(shù)據(jù)混亂不說,如果后面再也不來數(shù)據(jù)了,線程1就是死循環(huán)啦。

      2. 寫

      在異步socket中,寫是唯一一個主動點的操作,但是也不能直接去寫Channel,而是應(yīng)當(dāng)先把自身注冊為OP_WRITABLE,這時Selector就會發(fā)現(xiàn)你的存在,并把給發(fā)一個write事件,你這時后就可以寫了,不過這時候有個小小的技巧,就是你執(zhí)行寫操作之前,請取消掉你的寫注冊,否則你的cpu肯定是100%。

      3. 等待

      在傳統(tǒng)的服務(wù)器編程中,由于對于每個請求都是產(chǎn)生的一個線程,因此你在你每個請求線程中wait也好,sleep也好,不會影響別人。但是異步不同,他的主線程只有一個,基本上每個處理都是線性的,也就是說處理完第一個,然后才能處理第二個,因此nio是一個極好的處理短連接的架構(gòu)。

      我們現(xiàn)在出現(xiàn)的問題是,有人受同步的影響,沒有搞清異步是如何處理,竟然在方法處理中用上sleep,而且一等還是3秒,這意味著什么,3秒才能處理一個請求,My
      god,我要一個3秒才能處理一個請求的服務(wù)器干嘛啊,還是60年代?。海?/p>

      如果出現(xiàn)這樣的需要等待的情況,應(yīng)當(dāng)另起一個線程(推薦使用線程池)去完成這個“長”時間的任務(wù),或者將其它交給一個消息隊列,通過發(fā)消息的方式將給別人去完成也行,客戶端能等,你服務(wù)器怎么也能等呢?寫出這樣的代碼,基本上一個服務(wù)器也就廢了。

      贊(0)
      分享到: 更多 (0)
      網(wǎng)站地圖   滬ICP備18035694號-2    滬公網(wǎng)安備31011702889846號